From e743f61d144d58623410352396440efe5d3f46ca Mon Sep 17 00:00:00 2001 From: jackwotherspoon Date: Mon, 29 May 2023 16:10:47 +0000 Subject: [PATCH] chore: lint --- lib/sqlalchemy/dialects/postgresql/asyncpg.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/lib/sqlalchemy/dialects/postgresql/asyncpg.py b/lib/sqlalchemy/dialects/postgresql/asyncpg.py index 172917e773..efb758a00f 100644 --- a/lib/sqlalchemy/dialects/postgresql/asyncpg.py +++ b/lib/sqlalchemy/dialects/postgresql/asyncpg.py @@ -235,7 +235,6 @@ class AsyncPgInterval(INTERVAL): @classmethod def adapt_emulated_to_native(cls, interval, **kw): - return AsyncPgInterval(precision=interval.second_precision) @@ -496,7 +495,6 @@ class AsyncAdapt_asyncpg_cursor: adapt_connection = self._adapt_connection async with adapt_connection._execute_mutex: - if not adapt_connection._started: await adapt_connection._start_transaction() @@ -598,7 +596,6 @@ class AsyncAdapt_asyncpg_cursor: class AsyncAdapt_asyncpg_ss_cursor(AsyncAdapt_asyncpg_cursor): - server_side = True __slots__ = ("_rowbuffer",) @@ -876,7 +873,9 @@ class AsyncAdapt_asyncpg_dbapi: def connect(self, *arg, **kw): async_fallback = kw.pop("async_fallback", False) - creator_fn = kw.pop("creator_fn", functools.partial(self.asyncpg.connect)) + creator_fn = kw.pop( + "creator_fn", functools.partial(self.asyncpg.connect) + ) prepared_statement_cache_size = kw.pop( "prepared_statement_cache_size", 100 ) @@ -1076,7 +1075,6 @@ class PGDialect_asyncpg(PGDialect): @classmethod def get_pool_class(cls, url): - async_fallback = url.query.get("async_fallback", False) if util.asbool(async_fallback): -- 2.47.3