Fixed the csv_import

sql_analysis.md

@@ -3,7 +3,7 @@
 select sum(room.total_revenue::float)
 	
 	from alpinebits.conversions as con 
-	join alpinebits.room_reservations as room on room.conversion_id = con.id
+	join alpinebits.conversion_rooms as room on room.conversion_id = con.id
 	join alpinebits.reservations as res on res.id = con.reservation_id
 	
 	
@@ -21,7 +21,7 @@ select res.created_at, con.reservation_date, res.start_date, room.arrival_date,r
 	room.room_status
 	
 	from alpinebits.conversions as con 
-	join alpinebits.room_reservations as room on room.conversion_id = con.id
+	join alpinebits.conversion_rooms as room on room.conversion_id = con.id
 	join alpinebits.reservations as res on res.id = con.reservation_id
 	
 	
@@ -37,7 +37,7 @@ select res.created_at, con.reservation_date, res.start_date, room.arrival_date,r
 select round(sum(room.total_revenue::numeric)::numeric, 3), con.advertising_medium
 	
 	from alpinebits.conversions as con 
-	join alpinebits.room_reservations as room on room.conversion_id = con.id
+	join alpinebits.conversion_rooms as room on room.conversion_id = con.id
 
 	
 	

src/alpine_bits_python/api.py

@@ -1161,13 +1161,16 @@ async def _process_csv_import_background(
         _LOGGER.info("Starting database processing of %s", filename)
 
         # Create a new session for this background task
-        async with session_maker() as db_session:
+        db_session = await session_maker.create_session()
+        try:
             importer = CSVImporter(db_session, config)
             stats = await importer.import_csv_file(str(log_filename), hotel_code, dryrun=False)
 
             _LOGGER.info(
                 "CSV import complete for %s: %s", filename, stats
             )
+        finally:
+            await db_session.close()
     except Exception:
         _LOGGER.exception(
             "Error processing CSV import in background for %s", filename