@@ -135,10 +135,7 @@ async def _get_cursor(self, *params, **kwargs):
135135 async def _execute (self , params , one ):
136136 if one :
137137 rv = await self ._prepared .fetchrow (* params )
138- if rv is None :
139- rv = []
140- else :
141- rv = [rv ]
138+ rv = [] if rv is None else [rv ]
142139 else :
143140 rv = await self ._prepared .fetch (* params )
144141 return self ._prepared .get_statusmsg (), rv
@@ -211,10 +208,7 @@ async def execute_baked(self, baked_query, timeout, args, one):
211208
212209 if one :
213210 rv = await stmt .fetchrow (* args , timeout = timeout )
214- if rv is None :
215- rv = []
216- else :
217- rv = [rv ]
211+ rv = [] if rv is None else [rv ]
218212 else :
219213 rv = await stmt .fetch (* args , timeout = timeout )
220214 self ._attributes = stmt .get_attributes ()
@@ -342,7 +336,7 @@ class NullPool(base.Pool):
342336 # TODO: generic NullPool, abstracting connection part
343337 def __init__ (self , url , loop , ** kwargs ):
344338 self ._loop = loop
345- self ._kwargs = dict ()
339+ self ._kwargs = {}
346340 for k in inspect .getfullargspec (asyncpg .connect ).kwonlyargs :
347341 if k in kwargs :
348342 self ._kwargs [k ] = kwargs [k ]
@@ -664,7 +658,6 @@ async def has_type(self, connection, type_name, schema=None):
664658 AND n.nspname = :nspname
665659 )
666660 """
667- query = sql .text (query )
668661 else :
669662 query = """
670663 SELECT EXISTS (
@@ -673,7 +666,7 @@ async def has_type(self, connection, type_name, schema=None):
673666 AND pg_type_is_visible(t.oid)
674667 )
675668 """
676- query = sql .text (query )
669+ query = sql .text (query )
677670 query = query .bindparams (
678671 sql .bindparam (
679672 "typname" ,
0 commit comments