diff --git a/src/models/chunk_model.py b/src/models/chunk_model.py index c982019..07b6482 100644 --- a/src/models/chunk_model.py +++ b/src/models/chunk_model.py @@ -81,6 +81,9 @@ def add_chunk(upload_id, chunk_index): with get_db() as conn: cursor = conn.cursor() + # Use IMMEDIATE transaction to prevent race conditions with parallel uploads + cursor.execute("BEGIN IMMEDIATE") + # Get current received_chunks row = cursor.execute(""" SELECT received_chunks FROM chunk_sessions WHERE upload_id = ?