Итак, у меня есть задача, которая создает рабочий каталог и выполняет всю свою работу там. Задача вызывается с сервера A и выполняется на рабочих серверах . Мне нужно убедиться, что рабочий каталог будет удален после выполнения задачи/ отмены ....

Я попытался с помощью этого кода попытаться динамически добавить / удалить запланированные задачи. Мой файл tasks.py выглядит так: from celery.decorators import task import logging log = logging.getLogger(__name__) @task def mytask():...

Я использую Redis и Celery вместе для проекта django. [Предварительное условие] django==1.5.4 Redis==2.2.4 Celery==3.0.23 django-redis==3.7.1 django-celery==3.0.23 [Структура каталогов] Project/ apps/ app_1/...

У меня есть довольно сложный рабочий процесс (который строится динамически), который выглядит примерно так: workflow= chain( signature('workflow.tasks.start_workflow', kwargs= {}), chord( [ signature('workflow.tasks.group_task',...

Я демонизирую сельдерей, следуя документам . Мой BROKER_URL был установлен в следующем формате: - 'amqp://<user>:<password>@<ip>/<vhost>' . Итак, когда я запускаю сельдерей вручную, celery worker -A app_name , он...

Я использую сельдерей в проекте django. Я пробовал использовать rabbitmq и бэкэнд redis, но они не работают. Используемая версия сельдерея — 3.1.26.post2. Мне нужно вызвать 2, 3 иногда 5 раз, task.delay() чтобы увидеть выполнение задачи. А иногда...