소스 검색

fix for hpc queue check

Avik Datta 4 년 전
부모
커밋
0ca67ab8aa
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      dags/dag1_calculate_hpc_worker.py

+ 2 - 2
dags/dag1_calculate_hpc_worker.py

@@ -65,10 +65,10 @@ with dag:
 
   check_hpc_queue = \
     SSHOperator(
-      task_id='fetch_active_jobs_from_hpc',
+      task_id='check_hpc_queue',
       ssh_hook=hpc_hook,
       dag=dag,
-      command='qstat',
+      command='source /etc/bashrc;qstat',
       queue='igf-lims'
     )