#97 Change db.commit data place in processing

vincentnam · Oct 5, 2021 · f611d50 · f611d50
1 parent 333e5d1
commit f611d50
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/process_zone/apache_airflow/dags/services/extract_transform_load_dump_sql.py b/process_zone/apache_airflow/dags/services/extract_transform_load_dump_sql.py
@@ -86,8 +86,8 @@ def extract_transform_load_sql_dump(swift_result, swift_container, swift_id, pro
 
         # Execute SQL select statement
         cursor.executemany(insert_into, values)
-
-    db.commit()
+        db.commit()
+
     # Close the connection
     db.close()