From f00e841d072512723c3ac5f8b0ae7dec5a496dc4 Mon Sep 17 00:00:00 2001 From: Ian Costanzo Date: Fri, 5 Jul 2024 12:01:56 -0700 Subject: [PATCH] Set connections to autocommit to avoid transaction conflicts Signed-off-by: Ian Costanzo --- data-pipeline/bcreg/bcreg_core.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/data-pipeline/bcreg/bcreg_core.py b/data-pipeline/bcreg/bcreg_core.py index ebc3f05..7137064 100644 --- a/data-pipeline/bcreg/bcreg_core.py +++ b/data-pipeline/bcreg/bcreg_core.py @@ -56,6 +56,7 @@ def __init__(self, cache=False): self.conn.set_session(readonly=True) #self.conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_READ_COMMITTED) self.conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_REPEATABLE_READ) + self.conn.autocommit = True # Register the adapter sqlite3.register_adapter(decimal.Decimal, adapt_decimal) @@ -70,6 +71,7 @@ def __init__(self, cache=False): self.sec_conn.set_session(readonly=True) #self.sec_conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_READ_COMMITTED) self.sec_conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_REPEATABLE_READ) + self.sec_conn.autocommit = True except (Exception) as error: LOGGER.error(error) LOGGER.error(traceback.print_exc())