Sfoglia il codice sorgente

switching to ssh conn

Avik Datta 4 anni fa
parent
commit
6aef004013
1 ha cambiato i file con 6 aggiunte e 6 eliminazioni
  1. 6 6
      dags/dag1_calculate_hpc_worker.py

+ 6 - 6
dags/dag1_calculate_hpc_worker.py

@@ -14,12 +14,12 @@ args = {
     'provide_context': True,
     'provide_context': True,
 }
 }
 
 
-hpc_hook = SSHHook(
-      remote_host=Variable.get('hpc_host'),
-      username=Variable.get('hpc_user'),
-      key_file=Variable.get('igf_lims_ssh_key_file')
-    )
-
+#hpc_hook = SSHHook(
+#      remote_host=Variable.get('hpc_host'),
+#      username=Variable.get('hpc_user'),
+#      key_file=Variable.get('igf_lims_ssh_key_file')
+#    )
+hpc_hook = SSHHook(ssh_conn_id='hpc_conn')
 
 
 dag = DAG(
 dag = DAG(
         dag_id='dag1_calculate_hpc_worker',
         dag_id='dag1_calculate_hpc_worker',