admin管理员组

文章数量:1023758

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

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

本文标签: google cloud platformAirflow SSH Operator bash commands are failing IntermittentlyStack Overflow