Время ожидания сердцебиения Rabbitmq через 60 секунд из-за длительной задачи инициализации в сельдерее - PullRequest
0 голосов
/ 05 мая 2020

У меня есть код сельдерея

@app.task()
def task1():
    heartbeat_task()

@worker_ready.connect()
def long_running_task():
    task_runs_for_hour()

Есть другие периодические c задачи, которые отправляются работнику.

Dockerfile celery command 
celery -A tasks worker -B -l=INFO

Что происходит, я запускаю это в формате docker -compose с rabbitmq в другом контейнере. Однако я получаю ошибку сердцебиения rabbitmq из-за тайм-аута 60 секунд для моей длительной задачи.

Есть ли способ увеличить время ожидания сердцебиения rabbitmq?

...