From 104ac5fd6ddbe92ea9babe7b90b9340806cb7fb5 Mon Sep 17 00:00:00 2001
From: Jonas Linter <{email_address}>
Date: Tue, 18 Nov 2025 18:37:30 +0100
Subject: [PATCH] Fixed the csv_import

---
 sql_analysis.md               | 6 +++---
 src/alpine_bits_python/api.py | 5 ++++-
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/sql_analysis.md b/sql_analysis.md
index 6fda419..d580957 100644
--- a/sql_analysis.md
+++ b/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
 
 	
 	
diff --git a/src/alpine_bits_python/api.py b/src/alpine_bits_python/api.py
index d445754..a7d56d0 100644
--- a/src/alpine_bits_python/api.py
+++ b/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