diff --git a/changes/2946.fix.md b/changes/2946.fix.md new file mode 100644 index 0000000000..2176d57eb0 --- /dev/null +++ b/changes/2946.fix.md @@ -0,0 +1 @@ +Set the `postgres_readonly` flag to `false` when begin generic sessions diff --git a/src/ai/backend/manager/models/utils.py b/src/ai/backend/manager/models/utils.py index 0dc596e8ea..2731b9fce4 100644 --- a/src/ai/backend/manager/models/utils.py +++ b/src/ai/backend/manager/models/utils.py @@ -103,7 +103,10 @@ async def _begin(self, connection: SAConnection) -> AsyncIterator[SAConnection]: """ Begin generic transaction within the given connection. """ - async with connection.begin(): + conn_with_exec_opts = await connection.execution_options( + postgresql_readonly=False, + ) + async with conn_with_exec_opts.begin(): self._generic_txn_count += 1 self._check_generic_txn_cnt() try: