celery-task- все статьи тега


Сельдерей задачи не бросая исключение в тестах Django

У меня есть пара заданий на сельдерей, которые включены в мои тесты Django. К сожалению, исключения не создаются, когда задачи вызываются через .delay () . Я устанавливаю CELERY_ALWAYS_EAGER в True. Tasks.py import celeryapp as app @app.task() def exception_task(): print 'CELERY_ALWAYS_EAGER:', app.conf['CELERY_ALWAYS_EAGER'] raise Exception('foo') Tests.py def test_exception_in_task(self): from tasks import exception_task exception_task.delay() Вывод CELE ...

Удаление всех отложенных задач в celery / rabbitmq

Как я могу удалить все отложенные задачи, не зная task_id для каждой задачи? ...

Как я могу запустить периодическую задачу сельдерея из оболочки вручную?

Я использую сельдерей и Джанго-сельдерей. Я определил периодическую задачу, которую я хотел бы проверить. Можно ли запустить периодическую задачу из оболочки вручную, чтобы я мог просматривать вывод консоли? ...