浏览代码

minor fix

Avik Datta 4 年之前
父节点
当前提交
796e0a2416
共有 1 个文件被更改,包括 1 次插入1 次删除
  1. 1 1
      dags/dag1_calculate_hpc_worker.py

+ 1 - 1
dags/dag1_calculate_hpc_worker.py

@@ -77,7 +77,7 @@ with dag:
       task_id='fetch_active_jobs_from_hpc',
       ssh_hook=hpc_hook,
       dag=dag,
-      command='/project/tgu/data2/airflow_test/github/igf-airflow-hpc;python scripts/hpc/count_active_jobs_in_hpc.py',
+      command='cd /project/tgu/data2/airflow_test/github/igf-airflow-hpc;python scripts/hpc/count_active_jobs_in_hpc.py',
       do_xcom_push=True,
       queue='igf-lims'
     )