Refine logic around rollback and commit

nrccua · Feb 8, 2021 · 1c65b83 · 1c65b83
1 parent 09c3558
commit 1c65b83
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/aioradio/file_ingestion.py b/aioradio/file_ingestion.py
@@ -114,8 +114,9 @@ def child_wrapper(*args, **kwargs) -> Any:
 
                 if rollback[name]:
                     conn.rollback()
+                else:
+                    conn.commit()
 
-                conn.commit()
                 conn.close()
                 print(f"CLOSED CONNECTION for {name}")