django-postgres-queue
django-postgres-queue copied to clipboard
gavinwahl
A task queue for django
You have multiple queues created. e.g. ``` queue1 = AtLeastOnceQueue(tasks={'task1': task1}) queue2 = AtLeastOnceQueue(tasks={'task2': task2}) ``` Once woken, workers will work through all the tasks on the main job table....
this seems very cool, I'm going to use it in rabbitmq, amqp, kafka etc the name of a queue is an important design capability for example, you might have a...
- [x] Worker/Queue implentation boilerplate - [x] Comparison to celery (no funny business -- automatically importing your code, importing code by string, autodiscovery) - [x] mention not to use transaction.on_commit...
After using this library in production for a while I have found that the current approach of keeping track of failed tasks in a `set` in memory doesn't work in...
I noticed that the testproj doesn't work with Django 2.0 or newer so I fixed that. Django 1.11 also doesn't support anything above Python 3.7 it might be time to...
I thought it would be a neat addition to support auto-reload like `django-admin runserver` does. That is usually what you want while developing.
``` File "dpq/commands.py", line 82, in handle self.wait() File "dpq/commands.py", line 89, in wait count = len(self.queue.wait(self.delay)) ^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "dpq/queue.py", line 60, in wait connection.connection.poll() ^^^^^^^^^^^^^^^^^^^^^^^^^^ AttributeError: 'Connection' object has...