We are currently running multiple bash commands through Airflow 2.7.3 version under Google Cloud Composer.
from airflow.providers.ssh.operators.ssh import SSHOperator
task_exec = SSHOperator(
task_id='additonal_info',
command="ksh -x execute.ksh paramter1",
ssh_conn_id="SSH_CONNECTION",
conn_timeout=432000,
)
Sometimes command runs for 1 hour , sometime to 8 hours and sometimes with in 30-40 minutes commands fails with returning no error at the bottom of Airflow task but it will be failed state in Airflow.
Could any one pls suggest what can be done to fix this issue
发布者:admin,转转请注明出处:http://www.yc00.com/questions/1745601910a4635451.html
评论列表(0条)