Avik Datta преди 4 години
родител
ревизия
493318c615
променени са 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='python /path/count_job_script.py',
+      command='/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'
     )