I had this error for almost an hour but found a solution resulting into a big worrying dilemma. The solution let to realization that one cannot run gcloud app deploy while there is a task in the ta...

I want to test that the job has been released back onto the queue in certain circumstances. This is my job class: class ChargeOrder extends Job { use InteractsWithQueue, SerializesModels; /** ...

How can a function rate-limit its calls? The calls should not be discarded if too frequent, but rather be queued up and spaced out in time, X milliseconds apart. I've looked at throttle and debounc...

I have a Job to perform send SMS to user. I want to run this job on the specify queue-name. For example, this job added to "SMS" queue. So I found a way to do this but it's exists some er...

I have a directed acyclic graph in networkx. Each node represents a task and a nodes' predecessors are task dependencies (a given task cannot execute until its' dependencies have executed). I'd li...

TL;DR: How can I return data from a queued Job without saving it anywhere and handling the situation when the job might run more than once because of retries? Or is there another way if Jobs are no...

I am building a web app with node.js and mongodb. I need to add delayed jobs. For example, sending users an email one month after signing up. I haven't found an existing solution for delayed jobs b...

I'd like to use django_rq and rq-scheduler for offline tasks, but I'm unsure of where to call rq-scheduler's ability to schedule repeating tasks. Right now, I've added my scheduling to a tasks.py m...

I am currently trying to implement a job queue in php. The queue will then be processed as a batch job and should be able to process some jobs in parallel. I already did some research and found sev...

I am using the Flask-Mail library for my Flask application to send a default welcome email to the user when they sign up to be added to the newsletter. After debugging the library I found that it c...

In a Postgres 12 database, I have multiple queries (SELECT, UPDATE, ...) in a function that all together take about 20 minutes to complete. I have a check at the top that does an UPDATE if status i...

Worker: def worker(): while True: fruit, colour = q.get() print 'A ' + fruit + ' is ' + colour q.task_done() Putting items into queue: fruit = 'banana' colour = 'yellow' q.put(fruit, colour...

why is my queue job timing out? I am using database as a driver I tried the following: class PdfGenerator implements ShouldQueue { use Dispatchable, InteractsWithQueue, Queueable, SerializesModels...

I am running a Django application that runs asynchronous tasks using Celery and using a Redis server as a worker. I need to be able to stop the entire infrastructure and bring it back up without c...

I need a task queue so that some of the heavy operations can be moved out of the uwsgi context without affecting the users. Since we're already using uwsgi app server, it'd be desirable if uwsgi sp...

I need to access bull-queue to view job stats and show on the page. I'm using bull-repl to access the queue from CLI, as follows: > bull-repl BULL-REPL> connect marathon reddis://localhost...

As I understand message brokers like RabbitMQ facilitates different applications written in different language/platform to communicate with each other. So since celery can use RabbitMQ as message b...

We have recently forced to replace celery with RQ as it is simpler and celery was giving us too many problems. Now, we are not able to find a way to create multiple queues dynamically because we ne...

I am looking for a python library / framework that manages task distribution (e.g. a task queue). However, tasks will require specialized workers: Worker A can only handle tasks of type a, workers ...

I want to secure my Task Queue URLs against malicious access. In the views that the Task Queue requests I've got: if not users.is_current_user_admin(): return HttpResponse(status=403) But my T...

What is a good aproach to handle background processes in a NodeJS application? Scenario: After a user posts something to an app I want to crunch the data, request additional data from external re...

I have an application that receives messages of three types from multiple users at same time and I am handling it using 3 queues/consumers and 3 exchanges. My problem is that when there are thousan...

I have a Flask application, which is registered as follows: APP = Flask(__name__) APP.config.from_object('config') I have defined a view for a URL, in which a function is called, which interacts...

I'm trying to schedule an email to remind users who have to-do tasks due tomorrow. I made a custom command email:reminder. Here is my code in custom command: <?php namespace App\Console\Comman...

I'm a newbie with Rabbitmq(and programming) so sorry in advance if this is obvious. I am creating a pool to share between threads that are working on a queue but I'm not sure if I should use connec...