From 1c65b833626ac2d5c63ed73ac494a50af77341e6 Mon Sep 17 00:00:00 2001
From: "tim.reichard" <tim.reichard@nrccua.org>
Date: Mon, 8 Feb 2021 08:57:35 -0600
Subject: [PATCH] Refine logic around rollback and commit

---
 aioradio/file_ingestion.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/aioradio/file_ingestion.py b/aioradio/file_ingestion.py
index 4590ce5..f82255b 100644
--- 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}")