Avik Datta 3 years ago
parent
commit
f132842b70
1 changed files with 1 additions and 1 deletions
  1. 1 1
      dags/dag1_calculate_hpc_worker.py

+ 1 - 1
dags/dag1_calculate_hpc_worker.py

@@ -17,7 +17,7 @@ args = {
 hpc_hook = SSHHook(ssh_conn_id='hpc_conn')
 hpc_hook = SSHHook(ssh_conn_id='hpc_conn')
 
 
 dag = DAG(
 dag = DAG(
-        dag_id='dag_1_calculate_hpc_worker',
+        dag_id='dag1_calculate_hpc_worker',
         catchup=False,
         catchup=False,
         max_active_runs=1,
         max_active_runs=1,
         schedule_interval="*/15 * * * *",
         schedule_interval="*/15 * * * *",