소스 검색

added tags to dag

Avik Datta 4 년 전
부모
커밋
936a4edb7e
5개의 변경된 파일5개의 추가작업 그리고 0개의 파일을 삭제
  1. 1 0
      dags/dag2_disk_usage.py
  2. 1 0
      dags/dag3_hpc_pipelines.py
  3. 1 0
      dags/dag4_lims_metadata.py
  4. 1 0
      dags/dag5_primary_analysis_and_qc_processing.py
  5. 1 0
      dags/dag6_seqrun_processing.py

+ 1 - 0
dags/dag2_disk_usage.py

@@ -45,6 +45,7 @@ dag = \
     dag_id='dag2_disk_usage',
     schedule_interval=None,
     max_active_runs=1,
+    tags=['igf-lims','hpc','eliot','woolf','orwell'],
     default_args=default_args)
 
 with dag:

+ 1 - 0
dags/dag3_hpc_pipelines.py

@@ -20,6 +20,7 @@ dag = \
     catchup=False,
     schedule_interval=None,
     max_active_runs=1,
+    tags=['hpc'],
     default_args=default_args)
 
 with dag:

+ 1 - 0
dags/dag4_lims_metadata.py

@@ -20,6 +20,7 @@ dag = \
     catchup=False,
     schedule_interval=None,
     max_active_runs=1,
+    tags=['hpc'],
     default_args=default_args)
 
 with dag:

+ 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=None,
     max_active_runs=1,
+    tags=['hpc','orwell'],
     default_args=default_args)
 
 with dag:

+ 1 - 0
dags/dag6_seqrun_processing.py

@@ -22,6 +22,7 @@ dag = \
     catchup=False,
     schedule_interval=None,
     max_active_runs=1,
+    tags=['hpc','orwell'],
     default_args=default_args)
 
 orwell_ssh_hook = \