Можно ли запустить группу с цепями в сельдерее? - PullRequest
Новая
       5

Можно ли запустить группу с цепями в сельдерее?

0 голосов
/ 28 ноября 2018

Я пытаюсь запустить несколько цепочек внутри группы, и по какой-то причине она блокируется или задача не запускается вообще.Он просто останавливается и останавливается.

По сути, код сводится к следующему: 

group([
       chained_tasks[0],
       chained_tasks[1]
      ]
      ).apply_async()

, который зависает навсегда, я был бы признателен за любую помощь, я проверил backendresult и rabbitmq, они работают нормально.Я даже могу выполнить chained_tasks [0] .apply_async (), и он работает правильно.

вот как выглядит цепочка: 

job_chain = (
                process_task.s(chip_measurement_object.raw_result_ref,
                               process_args,
                               process_args['file_path'],
                               process_args['meas_data'],
                               process_args['marker_data'],
                               process_args['session']
                               ) |

                update_marker_data.s() |

                plot_task.s(chip_measurement_object.id) |

                grade_task.s(chip_measurement_object.id) |

                postgres_async_res_update.s(chip_measurement_object.id, self.input_args)
)

задачи специально изменяемы, потому что мне нужнораспространять результат задания родителей.

и вот мои настройки: 

# Sensible settings for celery
CELERY_ALWAYS_EAGER = False
CELERY_ACKS_LATE = True
CELERY_TASK_PUBLISH_RETRY = True
CELERY_DISABLE_RATE_LIMITS = False

# By default we will not ignore result
# If you want to see results and try out tasks_old interactively, change it to False
# Or change this setting on tasks_old level
CELERY_IGNORE_RESULT = False
CELERY_SEND_TASK_ERROR_EMAILS = False
CELERY_TASK_RESULT_EXPIRES = 600
...