这个问题通常与在使用DockerOperator时使用了不被支持的参数有关。解决方法是删除'mounts'参数。例如,如果您的DockerOperator代码看起来像这样:
t = DockerOperator( task_id='task', image='docker_image', api_version='auto', auto_remove=True, mounts=[('/var/run/docker.sock', '/var/run/docker.sock', 'rw')] ...)
移除'mounts'参数,代码将变为:
t = DockerOperator( task_id='task', image='docker_image', api_version='auto', auto_remove=True, ...)
这应该能够解决这个问题。
上一篇:AirFlow未运行调度计划。
下一篇:Airflow未找到本地文件