Почему Celery отменяет все запланированные задачи и отбрасывает их?

Question

У меня проблема с сельдереем: с определенной точки (журналы работников сельдерея не показывают первопричины), все задачи (запланированные celerybeat каждые 5 минут) отменяются и отбрасываются рабочими.

В журналах celerybeat и celeryd (рабочих) нет никакой подсказки, которая могла бы указать, почему это происходит. Я заметил, что с определенной точки 1/50 задача отменяется, частота отозванных задач продолжает расти, пока все задачи не будут систематически отменены 24 часа спустя.

Я использую Redis в качестве брокера, проблема возникает при развертывании Celery в Linux.

Вы знаете, что может быть причиной проблемы? Если вам нужна дополнительная информация, не стесняйтесь спрашивать!

Answer 1

я понял, что произошло после того, глядя на UUID, задачи в журналах:

[2015-10-27 05:27:45,879: INFO/MainProcess] Received task: hidden_task_name[29e47148-8865-4d46-a7ef-f8a0d625fe05] expires:[2015-10-27 05:57:45.870869+00:00] 
[2015-10-27 06:28:23,696: INFO/MainProcess] Discarding revoked task: hidden_task_name[29e47148-8865-4d46-a7ef-f8a0d625fe05] 

Задачи отбрасываются из-за истечения срока действия задачи я установить с помощью CELERYBEAT_SCHEDULE:

CELERYBEAT_SCHEDULE['---'] = { 
     'task': ..., 
     'schedule': ..., 
     'args':(), 
     'options': { 
      # Do not run the task if it starts 30 minutes after it is 
      # scheduled. This is useful if the Celery workers go down, 
      # celerybeat will keep adding tasks to the queue. 
      'expires': 1800 
     } 
    } 

Мои плохой)