diff --git a/backend/api/core/agent/persistence.py b/backend/api/core/agent/persistence.py index 419b49f..e70d8ba 100644 --- a/backend/api/core/agent/persistence.py +++ b/backend/api/core/agent/persistence.py @@ -30,7 +30,7 @@ async def checkpointer_context( # A compatible psycopg connection is created via the connection pool to connect to the checkpointer. async with AsyncConnectionPool( conninfo=conn_str, - kwargs=dict(prepare_threshold=None), + kwargs=dict(prepare_threshold=None, autocommit=True), ) as pool: checkpointer = AsyncPostgresSaver(pool) try: