Avik Datta преди 4 години
родител
ревизия
163a6d0864
променени са 3 файла, в които са добавени 4 реда и са изтрити 0 реда
  1. 2 0
      dags/dag1_calculate_hpc_worker.py
  2. 1 0
      dags/dag2_disk_usage.py
  3. 1 0
      dags/dag5_primary_analysis_and_qc_processing.py

+ 2 - 0
dags/dag1_calculate_hpc_worker.py

@@ -18,6 +18,8 @@ hpc_hook = SSHHook(ssh_conn_id='hpc_conn')
 
 dag = DAG(
         dag_id='dag1_calculate_hpc_worker',
+        catchup=False,
+        max_active_runs=1,
         schedule_interval="*/15 * * * *",
         default_args=args,
         tags=['igf-lims',]

+ 1 - 0
dags/dag2_disk_usage.py

@@ -45,6 +45,7 @@ dag = \
     dag_id='dag2_disk_usage',
     schedule_interval="@hourly",
     max_active_runs=1,
+    catchup=False,
     tags=['igf-lims','hpc','eliot','woolf','orwell'],
     default_args=default_args)
 

+ 1 - 0
dags/dag5_primary_analysis_and_qc_processing.py

@@ -28,6 +28,7 @@ dag = \
     dag_id='dag5_primary_analysis_and_qc_processing',
     schedule_interval="@hourly",
     max_active_runs=1,
+    catchup=False,
     tags=['hpc','orwell'],
     default_args=default_args)