这个问题可以通过设置no_rm=True
来解决。在Docker运行命令时添加这个参数,将防止Airflow尝试杀死正在运行的Docker容器。
示例代码:
from docker import Client
cli = Client(base_url='unix://var/run/docker.sock')
container_id = cli.create_container(
image='my_image',
command='/bin/sleep 10',
no_rm=True,
)['Id']
上一篇:Airflow尝试次数问题