Questions tagged [que]

Que is a postgres-based background worker library for Ruby.

Que is a background worker library for Ruby. Que is a high-performance alternative to DelayedJob or QueueClassic that improves the reliability of your application by protecting your jobs with the same ACID guarantees as the rest of your data.

https://github.com/chanks/que

23 questions
2
votes
0 answers

Spark can't connect to Hive metastore (NoSuchTableException)

I wrote this code, and run in a cluster with spark-submit: SUCCESS When I tray do this in Job (QUE) [Create Job][https://yadi.sk/i/GyOIRRsv_jVs-Q] I catch error NoSuchTableException: 2018-12-04 12:48:19,244 [main] WARN …
2
votes
1 answer

Use multiple connection in laravel queue

Using laravel 5.5, we need to use both Redis and SQS queues. Redis for our internal messaging and SQS for messages coming from a 3rd party. config/queue.php has various connection information. The first key is the default connection. That default is…
Scalable
  • 1,550
  • 4
  • 16
  • 29
2
votes
2 answers

Rails and Que jobs

Before I use sidekiq but now I decided to move to que and store everything in Postgresql. Because I don't need redis high-perfomance features I wanted to decrease dependency my application from external components. I add gem 'que', installed it and…
mystdeim
  • 4,802
  • 11
  • 49
  • 77
1
vote
0 answers

Rails 6 with Que and Dockerized PostgreSQL

I have a Rails 5.2 app on my local Mac with PostgreSQL 9.6 running on Docker. The app uses Que to process background jobs (version 0.12.3). To make things work, I originally added the following to my ~/.bash_profile (postgres9-6 is the name of the…
Sig
  • 5,476
  • 10
  • 49
  • 89
1
vote
1 answer

How do I run a limited number of background processes from laravel jobs?

I want to run ffmpeg processes from laravel jobs, but not too many all at once. I just can't seem to get it right. No matter what I set for $process_limit - It only runs one at a time and there are long delays in-between. Perhaps I'm using public…
Tarek Adam
  • 3,387
  • 3
  • 27
  • 52
1
vote
1 answer

Code for implementing queue with ring buffer

This is the part of a program for implementing queue with ring buffer in C. And I don't understand the line 8-9. What exactly does this line if(q->rear == q->max) q->rear = 0; mean? if the rear index equals the max capacity... then assign zero to…
1
vote
1 answer

Rabbit mq error: Getting Exception in thread "main" java.io.IOException Caused by: com.rabbitmq.client.ShutdownSignalException

Here is the error I get when I run my main. I do not really understand why it is having as issue with line 44: channel.basicConsume(Q,true,consumer); My goal here is to try and store the messages received into a variable that I can use in other…
Jas
  • 53
  • 1
  • 9
1
vote
1 answer

C++ add value into stack subscript requires array or pointer type and warning

I'm new to programming in C++. Also new to implementing stacks. My objective is creating RPN Calculator using template stack. Cant use the built in stack classes. I have everything so far and now I am stuck, I can't think of how to fix this problem.…
1
vote
1 answer

How to run Que jobs

I have installed the que gem and I would like to run the tasks I'm scheduling with active job, so far I have added in config/application.rb config.active_job.queue_adapter = :que and it stores the jobs in the database correctly but when I try to…
Boris Barroso
  • 1,802
  • 2
  • 22
  • 41
0
votes
2 answers

how to overload + operator to add two queues?

I want to add two queues I have defined, what's wrong with my overloading method ? I have tried the exact syntax of operator overloading but it did not work !! These queues are dynamic arrays that we define some operators for them in class of…
Sasan Ace
  • 23
  • 8
0
votes
2 answers

linked lists: or how to store a live qued-list properly

I'm working on a scheduler, for our internal production. the story of the problem is this: we have incoming 'jobs', that get sent to various stations 'machines'. we are storing the list of jobs in a mysql database. I want to make an interface for…
altruios
  • 986
  • 1
  • 10
  • 29
0
votes
1 answer

How to manually schedule job from AWS Lambda?

I want to replace my cron scheduler. Is there a way to schedule an ActiveJob from a Lambda and Cloudwatch? I'm using the Que gem.
0
votes
1 answer

Que failing with Distillery release and Docker

I have setup a Docker environment with Distillery to generate a release of my application. My Application uses Que to add a worker like so case Que.add(SyncWorker, %{}) do {:ok, _job} -> {:ok, "Syncing..."} err -> {:error, "Error…
Adam Bishti
  • 525
  • 2
  • 6
  • 16
0
votes
1 answer

Runnin a periodic task inside a GUI loop

i have a GUI running , showing some buttons. top = Tkinter.Tk() top.title('Interfaz') B = Tkinter.Button(top, text ="name1", command = name1) B.grid(row=0, column=0) C = Tkinter.Button(top, text ="name 2", command = name 2) C.grid(row=0, column=1) D…
0
votes
1 answer

s3 to ftp server without downloading to ec2

Is there is way (programmatically) to transfer file from s3 bucket to an external ftp server without downloading it to an ec2 instance ? More details: I have a Django server running on EC2 which serves an angular web app. User uploads a file to S3…
user4848830
  • 779
  • 12
  • 22
1
2