commented merge report generation

dags/dag16_test_illumina_demultiplexing.py

@@ -6,7 +6,7 @@ from airflow.operators.python_operator import PythonOperator
 from airflow.operators.python_operator import BranchPythonOperator
 from igf_airflow.utils.dag16_test_illumina_demultiplexing_utils import get_samplesheet_and_decide_flow_func
 from igf_airflow.utils.dag16_test_illumina_demultiplexing_utils import  run_demultiplexing_func
-from igf_airflow.utils.dag16_test_illumina_demultiplexing_utils import  prepare_merged_report_func
+#from igf_airflow.utils.dag16_test_illumina_demultiplexing_utils import  prepare_merged_report_func
 
 
 args = {
@@ -44,16 +44,16 @@ with dag:
                 'samplesheet_xcom_key': 'formatted_samplesheets'},
             python_callable=get_samplesheet_and_decide_flow_func)
     ## TASK
-    prepare_merged_report = \
-        PythonOperator(
-            task_id='prepare_merged_report',
-            dag=dag,
-            queue='hpc_4G',
-            params={
-                'samplesheet_xcom_task': 'get_samplesheet_and_decide_flow',
-                'samplesheet_xcom_key': 'formatted_samplesheets',
-                'output_path_xcom_key': 'temp_output_path'},
-            python_callable=prepare_merged_report_func)
+    # prepare_merged_report = \
+    #    PythonOperator(
+    #        task_id='prepare_merged_report',
+    #        dag=dag,
+    #        queue='hpc_4G',
+    #        params={
+    #            'samplesheet_xcom_task': 'get_samplesheet_and_decide_flow',
+    #            'samplesheet_xcom_key': 'formatted_samplesheets',
+    #            'output_path_xcom_key': 'temp_output_path'},
+    #        python_callable=prepare_merged_report_func)
     ## TASK
     for i in range(1, 9):
         t = \
@@ -70,5 +70,5 @@ with dag:
                     'output_path_xcom_key': 'temp_output_path'},
                 python_callable=run_demultiplexing_func)
         ## PIPELINE
-        get_samplesheet_and_decide_flow >> t >> prepare_merged_report
+        get_samplesheet_and_decide_flow >> t