Lines Matching refs:await

148     d = await client.get_taskhash(method, taskhash)
196             self.upstream_client = await create_async_client(self.upstream)
200         await super().process_requests()
203             await self.upstream_client.close()
210                     await self.handlers[k](msg[k])
214                         await self.handlers[k](msg[k])
225             d = await self.get_unihash(cursor, method, taskhash, fetch_all)
252                 d = await self.upstream_client.get_taskhash(method, taskhash, True)
261                 d = await self.upstream_client.get_taskhash(method, taskhash)
274             d = await self.get_outhash(cursor, method, outhash, taskhash)
298             d = await self.upstream_client.get_outhash(method, outhash, taskhash)
325             l = await self.reader.readline()
355                     upstream = await self.upstream_client.get_unihash(method, taskhash)
368             await self.writer.drain()
373                 await self.backfill_queue.put((method, taskhash))
425 …upstream_data = await self.upstream_client.get_outhash(data['method'], data['outhash'], data['task…
440             unihash_data = await self.get_unihash(cursor, data['method'], data['taskhash'])
499         await self.backfill_queue.join()
532             client = await create_async_client(self.upstream)
535                     item = await self.backfill_queue.get()
540                     await copy_unihash_from_upstream(client, self.db, method, taskhash)
543                 await client.close()
546             await self.backfill_queue.put(None)
547             await worker