I want to disable cache in asyncpg+postgresql to get timely results from the database and not outdated ones. However, I encounter an issue that doesn't allow me to do so: RuntimeWarning: coroutine 'AsyncConnection.execution_options' was never awaited async with engine.connect().execution_options(compiled_cache=None) RuntimeWarning:…
I'm using PostgreSQL & asyncpg. class PgDb: # noinspection SpellCheckingInspection def __init__(self, conn: asyncpg.connection.Connection): self.conn = conn async def select(self, sql: str, args: Union[list, Dict[str, Any]] = []) -> List[Dict[str, Any]]: sql, _args = self.__convert_placeholders(sql, args) return [dict(row) for row…
I have the following table: create table foo (id serial primary key, ts date, value int); Populated with 10k records already. Now I'm trying to find a way to efficiently update multiple rows in one go, so I wrote this…