vintasoftware / celery-tasks-checklist Goto Github PK

In case of outage make sure Celery will pick up the tasks that were supposed to run while the system was off (if this makes sense in your business logic).

Bad:

# Messages for some tasks won't be sent if the outage lasts one day
for task in Tasks.objects.filter(due_to=today):
    send_messages()

Better:

for task in Tasks.objects.filter(due_to__lte=today, sent=False):
   send_messages()

Since you may have tasks running and/or due to retry with old kwargs

http://docs.celeryproject.org/en/master/userguide/tasks.html#automatic-retry-for-known-exceptions

celery/celery#4101

Link to: https://www.vinta.com.br/blog/2016/database-concurrency-in-django-the-right-way/

https://github.com/vintasoftware/celery-tasks-checklist/blob/master/index.html#L170

please fix it asap.

Thanks