代码之家 › 专栏 › 技术社区 › Anthony Lee

如何在气流中重新启动芹菜工人

flower airflow celery docker bash

0

Anthony Lee · 技术社区 · 8 年前

我现在遇到了一个问题,我的芹菜工人偶尔会结冰,需要重新启动。我有一个气流实例,我想从中使用 BashOperator SSHOperator ,但我不知道如何继续,因为它在一个Docker容器中。

编辑: airflow is setting the config 现在,有什么方法可以替代这个吗?

1 回复 | 直到 8 年前

1

0

Anthony Lee 8 年前

t1 = BashOperator(
    task_id="celery_restart",
    bash_command="celery multi restart 1",
    dag=dag
)

并没有真正阻止我的任务挂起,但它确实存在:)。