changed trigger rule

imperial-genomics-facility · Feb 5, 2024 · cac29c7 · cac29c7
1 parent fdc9c36
commit cac29c7
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/igf_airflow/utils/dag33_geomx_processing_util.py b/igf_airflow/utils/dag33_geomx_processing_util.py
@@ -1203,6 +1203,7 @@ def copy_data_to_globus(analysis_dir_dict: dict) -> None:
     task_id="send_email_to_user",
     retry_delay=timedelta(minutes=5),
     retries=4,
+    trigger_rule="none_failed_min_one_success",
     queue='hpc_4G')
 def send_email_to_user(
         send_email: bool = True,

diff --git a/igf_airflow/utils/dag34_cellranger_multi_scRNA_utils.py b/igf_airflow/utils/dag34_cellranger_multi_scRNA_utils.py
@@ -1018,7 +1018,6 @@ def move_aggr_result_to_main_work_dir(
   retry_delay=timedelta(minutes=5),
   retries=4,
   queue='hpc_8G',
-  trigger_rule="none_failed",
   multiple_outputs=False)
 def calculate_md5sum_for_main_work_dir(main_work_dir: str) -> str:
   try:
@@ -1053,7 +1052,6 @@ def calculate_md5sum_for_main_work_dir(main_work_dir: str) -> str:
   task_id="load_cellranger_results_to_db",
   retry_delay=timedelta(minutes=5),
   retries=4,
-  trigger_rule="none_failed_min_one_success",
   queue='hpc_4G')
 def load_cellranger_results_to_db(
       main_work_dir: str,