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

我目前遇到一个问题，我的芹菜工人偶尔冻结，需要重新启动。 我有一个Airflow的实例，我想使用BashOperator或SSHOperator来configuration和重新启动，但是我不确定如何继续，因为它在Docker容器中。

从本地主机我只是“docker重启工人”，但由于Bash在气stream容器内运行，我需要find一种方法来重新启动通过气streamCLI或SSH从容器到主机，这听起来可怕。 有没有一个优雅的方法来处理这个问题？

编辑：我看到花有一个REST API，我可以重新启动池，但我必须在我的芹菜configuration启用。 它看起来像气stream设置已经configuration ，有没有什么办法来覆盖这个？

Answer 1

好的，这就是我最终做的事情：

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

不是真的阻止我的任务挂起，但它是:)。