147 async def copy_unihash_from_upstream(client, db, method, taskhash):  argument
148     d = await client.get_taskhash(method, taskhash)
221         taskhash = request['taskhash']
225             d = await self.get_unihash(cursor, method, taskhash, fetch_all)
229     async def get_unihash(self, cursor, method, taskhash, fetch_all=False):  argument
243                     'taskhash': taskhash,
252                 d = await self.upstream_client.get_taskhash(method, taskhash, True)
256             row = self.query_equivalent(cursor, method, taskhash)
261                 d = await self.upstream_client.get_taskhash(method, taskhash)
271         taskhash = request['taskhash']
274             d = await self.get_outhash(cursor, method, outhash, taskhash)
278     async def get_outhash(self, cursor, method, outhash, taskhash):  argument
298             d = await self.upstream_client.get_outhash(method, outhash, taskhash)
343                 (method, taskhash) = l.split()
347                     row = self.query_equivalent(cursor, method, taskhash)
355                     upstream = await self.upstream_client.get_unihash(method, taskhash)
373                 await self.backfill_queue.put((method, taskhash))
502     def query_equivalent(self, cursor, method, taskhash):  argument
508                 'taskhash': taskhash,
539                     method, taskhash = item
540                     await copy_unihash_from_upstream(client, self.db, method, taskhash)