@@ -184,13 +184,13 @@ async def __aexit__(
184184 async def fetch_all (
185185 self , query : typing .Union [ClauseElement , str ], values : dict = None
186186 ) -> typing .List [typing .Mapping ]:
187- async with self ._self . _query_lock :
187+ async with self ._query_lock :
188188 return await self ._connection .fetch_all (self ._build_query (query , values ))
189189
190190 async def fetch_one (
191191 self , query : typing .Union [ClauseElement , str ], values : dict = None
192192 ) -> typing .Optional [typing .Mapping ]:
193- async with self ._self . _query_lock :
193+ async with self ._query_lock :
194194 return await self ._connection .fetch_one (self ._build_query (query , values ))
195195
196196 async def fetch_val (
@@ -199,27 +199,27 @@ async def fetch_val(
199199 values : dict = None ,
200200 column : typing .Any = 0 ,
201201 ) -> typing .Any :
202- async with self ._self . _query_lock :
202+ async with self ._query_lock :
203203 row = await self ._connection .fetch_one (self ._build_query (query , values ))
204204 return None if row is None else row [column ]
205205
206206 async def execute (
207207 self , query : typing .Union [ClauseElement , str ], values : dict = None
208208 ) -> typing .Any :
209- async with self ._self . _query_lock :
209+ async with self ._query_lock :
210210 return await self ._connection .execute (self ._build_query (query , values ))
211211
212212 async def execute_many (
213213 self , query : typing .Union [ClauseElement , str ], values : list
214214 ) -> None :
215215 queries = [self ._build_query (query , values_set ) for values_set in values ]
216- async with self ._self . _query_lock :
216+ async with self ._query_lock :
217217 await self ._connection .execute_many (queries )
218218
219219 async def iterate (
220220 self , query : typing .Union [ClauseElement , str ], values : dict = None
221221 ) -> typing .AsyncGenerator [typing .Any , None ]:
222- async with self ._self . _query_lock :
222+ async with self ._query_lock :
223223 async for record in self ._connection .iterate (self ._build_query (query , values )):
224224 yield record
225225
0 commit comments