@@ -135,10 +135,7 @@ async def _get_cursor(self, *params, **kwargs):
135
135
async def _execute (self , params , one ):
136
136
if one :
137
137
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 ]
142
139
else :
143
140
rv = await self ._prepared .fetch (* params )
144
141
return self ._prepared .get_statusmsg (), rv
@@ -211,10 +208,7 @@ async def execute_baked(self, baked_query, timeout, args, one):
211
208
212
209
if one :
213
210
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 ]
218
212
else :
219
213
rv = await stmt .fetch (* args , timeout = timeout )
220
214
self ._attributes = stmt .get_attributes ()
@@ -342,7 +336,7 @@ class NullPool(base.Pool):
342
336
# TODO: generic NullPool, abstracting connection part
343
337
def __init__ (self , url , loop , ** kwargs ):
344
338
self ._loop = loop
345
- self ._kwargs = dict ()
339
+ self ._kwargs = {}
346
340
for k in inspect .getfullargspec (asyncpg .connect ).kwonlyargs :
347
341
if k in kwargs :
348
342
self ._kwargs [k ] = kwargs [k ]
@@ -664,7 +658,6 @@ async def has_type(self, connection, type_name, schema=None):
664
658
AND n.nspname = :nspname
665
659
)
666
660
"""
667
- query = sql .text (query )
668
661
else :
669
662
query = """
670
663
SELECT EXISTS (
@@ -673,7 +666,7 @@ async def has_type(self, connection, type_name, schema=None):
673
666
AND pg_type_is_visible(t.oid)
674
667
)
675
668
"""
676
- query = sql .text (query )
669
+ query = sql .text (query )
677
670
query = query .bindparams (
678
671
sql .bindparam (
679
672
"typname" ,
0 commit comments