FAQ Database Discussion Community


Check if a queue is empty in Google App Engine

python,django,google-app-engine,task-queue
I have a script that add tasks to a queue. For example: api.py: from google.appengine.api import taskqueue [...] for u in users: taskqueue.add(queue_name='mailqueue', url="/api/users/send-notification/%s" % (u.id), method='GET') I would like to check if the queue is empty and all tasks are finishing view.py: if queue_is_empty: print "Your task is finished"...

Managing Celery Task Results

python,redis,celery,task-queue
I am pretty new to Celery and I thought I had read somewhere that the task results only stay around for a limited time. However my backend (redis) is getting pretty bloated after running a lot of tasks through it. Is there a way to set a TTL on task...

Frame works for distributed scheduling task queue for a high scale

rabbitmq,akka,scalability,high-availability,task-queue
I need to build a system which requires atleast a hundred thousand jobs created /scheduled for a day. I looked into multiple task queues but there isnt much support for scheduling say like quartz in a distributed way, A good solution seems to be celery( i am a java guy...

Is it possible to execute a task inside Google App Engine taskqueue?

google-app-engine,task-queue
I want to do a unittest on a function inside Google App Engine taskqueue. I would like to know if there is any method by which we can execute the tasks in taskqueue so as to test whether it yields the desired output.

Laravel 5: Multiple workers - Cannot delete job XXXXXX: NOT_FOUND

laravel-5,task-queue
I'm creating a website using Laravel 5. I'm using queues with beanstalkd with 2 tubes. I have 10 workers monitored by daemontools. 5 workers process tube A and B. The other 5 workers only process tube B. Things work great most of the time, but occasionally tube B seems to...

Using GAE Task Queues for handling persistence operations

java,google-app-engine,java-ee,task-queue
Looking to get opinions on whether or not it would be a good idea to hand persistence operations off to a task queue. For example, a user submits a new 'order', I use bean validation to verify that everything is ok, and then hand over the processing/persisting of the order...

Why am I getting an empty pointer when dequeuing in FreeRTOS?

c,pointers,task-queue,freertos
I need to send some ascii character strings from one task to another. I need to send not the string but the address of the first character (as a reference to the string) to another task. The reason I want to send "a reference" to the string and not the...