Move handle_failure_and_cleanup_temp_tables to Db services to avoid in-function import

brian-kim31 · brian-kim31 · commit 94f4053e7478 · 2026-02-02T17:02:42.000Z
diff --git a/app/airflow/dags/SR_processing_dag.py b/app/airflow/dags/SR_processing_dag.py
@@ -7,12 +7,12 @@
     process_and_create_scan_report_entries,
     process_data_dictionary,
 )
+from libs.SR_processing.db_services import handle_failure_and_cleanup_temp_tables
 from libs.utils import (
     connect_to_storage,
     create_task,
     validate_params_SR_processing,
 )
-from libs.SR_processing.db_services import handle_failure_and_cleanup_temp_tables
 
 """
 This DAG automates the process of creating scan report tables, fields and values 

Original file line number	Diff line number	Diff line change
`@@ -7,12 +7,12 @@`
`7`	`7`	`process_and_create_scan_report_entries,`
`8`	`8`	`process_data_dictionary,`
`9`	`9`	`)`
	`10`	`+from libs.SR_processing.db_services import handle_failure_and_cleanup_temp_tables`
`10`	`11`	`from libs.utils import (`
`11`	`12`	`connect_to_storage,`
`12`	`13`	`create_task,`
`13`	`14`	`validate_params_SR_processing,`
`14`	`15`	`)`
`15`		`-from libs.SR_processing.db_services import handle_failure_and_cleanup_temp_tables`
`16`	`16`
`17`	`17`	`"""`
`18`	`18`	`This DAG automates the process of creating scan report tables, fields and values`