Do individual insert queries

vipyrsec · Jul 20, 2023 · 5f9429e · 5f9429e
1 parent b065b2c
commit 5f9429e
Showing 1 changed file with 3 additions and 10 deletions.
diff --git a/src/mainframe/endpoints/package.py b/src/mainframe/endpoints/package.py
@@ -203,16 +203,9 @@ async def batch_queue_package(
 
         rows.append(scan)
 
-    async with session.begin():
-        for row in rows:
-            try:
-                async with session.begin_nested():
-                    session.add(row)
-            except IntegrityError:
-                print("Skipping duplicate")
-                pass
-    await session.commit()
-    await session.close()
+    for scan in rows:
+        session.add(scan)
+        await session.commit()
 
 
 @router.post(