diff --git a/dev/workflow/TK_Cust/dag_unzip_datafile/数据文件解压缩/wf_dag_dag_unzip_datafile.py b/dev/workflow/TK_Cust/dag_unzip_datafile/数据文件解压缩/wf_dag_dag_unzip_datafile.py index aa890c0..3aabae9 100644 --- a/dev/workflow/TK_Cust/dag_unzip_datafile/数据文件解压缩/wf_dag_dag_unzip_datafile.py +++ b/dev/workflow/TK_Cust/dag_unzip_datafile/数据文件解压缩/wf_dag_dag_unzip_datafile.py @@ -41,7 +41,7 @@ task_failed = EmailOperator ( uds_uzip_upload_datafile = SSHOperator( ssh_hook=sshHook, task_id='uds_uzip_upload_datafile', -command='/data/airflow/bin/uzip_file /data/airflow/bin/uzip_upload_datafile.sh >>/data/airflow/logs/run_uzip_upload_datafile.log 2>&1 {{ ds_nodash }} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ', +command='/data/airflow/bin/uzip_file /data/airflow/bin/uzip_upload_datafile.sh >>/data/airflow/logs/run_uzip_upload_datafile.log 2>&1 ', params={'my_param':"uds_uzip_upload_datafile"}, depends_on_past=False, retries=3,