change to post_session2

QGEP · May 12, 2024 · 03a52ef · 03a52ef
1 parent 06699fa
commit 03a52ef
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/qgepqwat2ili/qgepdss/import_.py b/qgepqwat2ili/qgepdss/import_.py
@@ -78,7 +78,6 @@ def get_vl_instance(vl_table, value):
                 logger.warning(
                     f'Could not find value `{value}` in value list "{vl_table.__table__.schema}.{vl_table.__name__}". Setting to None instead.'
                 )
-            )
             return None
         return row
 
@@ -3809,10 +3808,11 @@ def overflow_common(row):
         logger.info("Comitting qgep_session - please be patient ...")
     else:
         # 11.5.2024 improve user feedback
-        logger.info("Comitting qgep_session - please be patient ...")
+        logger.info("Comitting qgep_session - please be patient (else) ...")
         qgep_session.commit()
         logger.info("qgep_session sucessfully committed")
         qgep_session.close()
+
     abwasser_session.close()
     logger.info("abwasser_session closed")
 
@@ -3832,15 +3832,15 @@ def overflow_common(row):
     post_session2 = Session(utils.sqlalchemy.create_engine(), autocommit=False, autoflush=False)
 
     logger.info("Update wastewater structure fk_main_cover")
-    cursor.execute("SELECT qgep_od.wastewater_structure_update_fk_main_cover('', True);")
+    post_session2.execute("SELECT qgep_od.wastewater_structure_update_fk_main_cover('', True);")
 
     logger.info("Update wastewater structure fk_main_wastewater_node")
-    cursor.execute(
+    post_session2.execute(
             "SELECT qgep_od.wastewater_structure_update_fk_main_wastewater_node('', True);"
     )
 
     logger.info("Refresh materialized views")
-    cursor.execute("SELECT qgep_network.refresh_network_simple();")
+    post_session2.execute("SELECT qgep_network.refresh_network_simple();")
 
     post_session2.commit()
     post_session2.close()