sqlalchemy and asyncpg – set postgres statement_timeout

Question

When doing

engine: AsyncEngine = create_async_engine(...)

and then

async with engine.connect() as conn:
    result: Result = await conn.execute(text("""..."""))

I would like to specify a timeout. Ideally I'd be able to set statement_timeout just for this one query execution. I am also fine with sqlalchemy doing the timeout and cancelling the query execution, but I can't find a way to set either.

Anton Myronyuk · Accepted Answer · 2023-02-28 10:43:04Z

4

command_timeout is set only on application level. It means query will still be running in database after timeout error in your application. To set timeout on database level you should use server_settings:

create_async_engine(
    db_url, connect_args={"server_settings": {"statement_timeout": "10000"}},
)

edited Feb 28, 2023 at 10:43

answered Feb 28, 2023 at 10:40

Anton Myronyuk

1063 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

Nikhil Popli · Accepted Answer · 2022-08-04 16:15:14Z

3

create_async_engine(
            db_url, connect_args={"command_timeout": 28.0}
        )

use command_timeout in connect_args in seconds

edited Aug 4, 2022 at 16:15

answered Aug 4, 2022 at 14:52

Nikhil Popli

614 bronze badges

Collectives™ on Stack Overflow

sqlalchemy and asyncpg – set postgres statement_timeout

2 Answers 2

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related