상황
airflow에서 새로운 Task를 추가해서 DAG을 돌리던 중 다음과 같은 에러가 발생
airflow.exceptions.AirflowException: SSH command timed out
새로운 Task는 SSHOperator를 이용해서 SSH에서 python script를 실행
원인 및 해결
에러가 발생하는 이유는 SSHOperator에서 cmd_timeout가 10초인데
그것보다 오래 실행되서 생긴 오류였다.
cmd_timeout를 적절히 올리면 해결
OJH