Parcourir la source

fix for missing ssh hook

Avik Datta il y a 4 ans
Parent
commit
35e9271356
1 fichiers modifiés avec 2 ajouts et 1 suppressions
  1. 2 1
      dags/dag8_copy_ongoing_seqrun.py

+ 2 - 1
dags/dag8_copy_ongoing_seqrun.py

@@ -25,7 +25,7 @@ default_args = {
 }
 
 
-## CONN HOOKS
+## SSH HOOKS
 orwell_ssh_hook = \
   SSHHook(
     key_file=Variable.get('hpc_ssh_key_file'),
@@ -241,6 +241,7 @@ with dag:
         task_id='generate_seqrun_file_list_{0}'.format(i),
         dag=dag,
         pool='orwell_exe_pool',
+        ssh_hook=orwell_ssh_hook,
         do_xcom_push=True,
         queue='hpc_4G',
         params={'source_task_id':'generate_seqrun_list',