Avik Datta %!s(int64=4) %!d(string=hai) anos
pai
achega
045c6be8d4
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  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='bash /project/tgu/data2/airflow_test/github/igf-airflow-hpc/scripts/hpc/hpc_job_count_runner.sh',
+      command='bash /project/tgu/data2/airflow_test/github/igf-airflow-hpc/scripts/hpc/hpc_job_count_runner.sh ',
       do_xcom_push=True,
       queue='igf-lims'
     )