t1 =SSHOperator(ssh_conn_id='test', task_id='ssh_test', command='python3 test.py', dag=dag)
只有如上这些配置,当任务启动的时候就会不断的报错:
airflow.exceptions.AirflowException: SSH command timed out
原因是上面的test.py脚本需要执行一段时间,但airflow并不等待执行结束就返回了结果,并报错。
相似问题