From 5f9429e422eb9c25c237a4cbe1f7092adf67a483 Mon Sep 17 00:00:00 2001 From: Robin5605 Date: Wed, 19 Jul 2023 20:24:13 -0500 Subject: [PATCH] Do individual insert queries --- src/mainframe/endpoints/package.py | 13 +++---------- 1 file changed, 3 insertions(+), 10 deletions(-) diff --git a/src/mainframe/endpoints/package.py b/src/mainframe/endpoints/package.py index 41a9b30e..02bef30b 100644 --- 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(