fix for import

dags/dag10_nextflow_atacseq_pipeline.py

@@ -5,14 +5,14 @@ from airflow.utils.dates import days_ago
 from airflow.operators.python_operator import PythonOperator
 from airflow.operators.python_operator import BranchPythonOperator
 from airflow.operators.dummy_operator import DummyOperator
-from igf_airflow.utils.dag10_nextflow_atacseq_pipeline import fetch_nextflow_analysis_info_and_branch_func
-from igf_airflow.utils.dag10_nextflow_atacseq_pipeline import prep_nf_run_func
-from igf_airflow.utils.dag10_nextflow_atacseq_pipeline import run_nf_command_func
-from igf_airflow.utils.dag10_nextflow_atacseq_pipeline import copy_nf_data_to_box_func
-from igf_airflow.utils.dag10_nextflow_atacseq_pipeline import copy_nf_data_to_irods_func
-from igf_airflow.utils.dag10_nextflow_atacseq_pipeline import nf_analysis_copy_branch_func
-from igf_airflow.utils.dag10_nextflow_atacseq_pipeline import change_pipeline_status
-from igf_airflow.utils.dag10_nextflow_atacseq_pipeline import copy_nf_output_to_disk_func
+from igf_airflow.utils.dag10_nextflow_atacseq_pipeline_utils import fetch_nextflow_analysis_info_and_branch_func
+from igf_airflow.utils.dag10_nextflow_atacseq_pipeline_utils import prep_nf_run_func
+from igf_airflow.utils.dag10_nextflow_atacseq_pipeline_utils import run_nf_command_func
+from igf_airflow.utils.dag10_nextflow_atacseq_pipeline_utils import copy_nf_data_to_box_func
+from igf_airflow.utils.dag10_nextflow_atacseq_pipeline_utils import copy_nf_data_to_irods_func
+from igf_airflow.utils.dag10_nextflow_atacseq_pipeline_utils import nf_analysis_copy_branch_func
+from igf_airflow.utils.dag10_nextflow_atacseq_pipeline_utils import change_pipeline_status
+from igf_airflow.utils.dag10_nextflow_atacseq_pipeline_utils import copy_nf_output_to_disk_func
 
 default_args = {
   'owner': 'airflow',