Цепная задача или зависимая задача с помощью celery и django

Я использую celery для управления запланированными задачами в моем приложении django. используя "app.conf.beat_schedule" я могу успешно запланировать задачу.

Но одна из моих задач зависит от другой запланированной задачи и принимает параметры, получаемые от нее. В этом случае я сталкиваюсь с проблемой, просматривая интернет, я запутался и не нашел ничего подходящего для себя.

Я попробовал следующее и он показывает: " Планировщик: Sending due task chained (celery_task_1)"

enter image description here

Внутри celery.py

import os
from celery import Celery, group


os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'config.settings')
app = Celery('config')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()


app.conf.beat_schedule = {
    'chained': {
        'task': 'celery_task_1',
        'schedule': 5.0,
        'args': (),
        'options': {
            'queue': 'default',
            'link': signature(
                'celery_task_2',
                args=(),
                kwargs={},
                queue='default'
            )
        }
    }
}
Вернуться на верх