diff --git a/awx/main/utils/pglock.py b/awx/main/utils/pglock.py index a47880b667..d599d284b3 100644 --- a/awx/main/utils/pglock.py +++ b/awx/main/utils/pglock.py @@ -17,13 +17,13 @@ def advisory_lock(*args, lock_session_timeout_milliseconds=0, **kwargs): with connection.cursor() as cur: idle_in_transaction_session_timeout = cur.execute('SHOW idle_in_transaction_session_timeout').fetchone()[0] idle_session_timeout = cur.execute('SHOW idle_session_timeout').fetchone()[0] - cur.execute(f"SET idle_in_transaction_session_timeout = {lock_session_timeout_milliseconds}") - cur.execute(f"SET idle_session_timeout = {lock_session_timeout_milliseconds}") + cur.execute(f"SET idle_in_transaction_session_timeout = '{lock_session_timeout_milliseconds}'") + cur.execute(f"SET idle_session_timeout = '{lock_session_timeout_milliseconds}'") with django_pglocks_advisory_lock(*args, **kwargs) as internal_lock: yield internal_lock if lock_session_timeout_milliseconds > 0: with connection.cursor() as cur: - cur.execute(f"SET idle_in_transaction_session_timeout = {idle_in_transaction_session_timeout}") - cur.execute(f"SET idle_session_timeout = {idle_session_timeout}") + cur.execute(f"SET idle_in_transaction_session_timeout = '{idle_in_transaction_session_timeout}'") + cur.execute(f"SET idle_session_timeout = '{idle_session_timeout}'") else: yield True