147 async def copy_unihash_from_upstream(client, db, method, taskhash):  argument
148     d = await client.get_taskhash(method, taskhash)
220         method = request['method']
225             d = await self.get_unihash(cursor, method, taskhash, fetch_all)
229     async def get_unihash(self, cursor, method, taskhash, fetch_all=False):  argument
236 …INNER JOIN unihashes_v2 ON unihashes_v2.method=outhashes_v2.method AND unihashes_v2.taskhash=outha…
237                 WHERE outhashes_v2.method=:method AND outhashes_v2.taskhash=:taskhash
242                     'method': method,
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)
269         method = request['method']
274             d = await self.get_outhash(cursor, method, outhash, taskhash)
278     async def get_outhash(self, cursor, method, outhash, taskhash):  argument
283 …INNER JOIN unihashes_v2 ON unihashes_v2.method=outhashes_v2.method AND unihashes_v2.taskhash=outha…
284             WHERE outhashes_v2.method=:method AND outhashes_v2.outhash=:outhash
289                 'method': method,
298             d = await self.upstream_client.get_outhash(method, outhash, taskhash)
343                 (method, taskhash) = l.split()
344                 #logger.debug('Looking up %s %s' % (method, taskhash))
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))
378                 'method': data['method'],
397 …INNER JOIN unihashes_v2 ON unihashes_v2.method=outhashes_v2.method AND unihashes_v2.taskhash=outha…
399 …WHERE outhashes_v2.method=:method AND outhashes_v2.outhash=:outhash AND outhashes_v2.taskhash!=:ta…
405                         'method': data['method'],
425 …upstream_data = await self.upstream_client.get_outhash(data['method'], data['outhash'], data['task…
433                         'method': data['method'],
440             unihash_data = await self.get_unihash(cursor, data['method'], data['taskhash'])
450                 'method': data['method'],
459                 'method': data['method'],
469             row = self.query_equivalent(cursor, data['method'], data['taskhash'])
475             d = {k: row[k] for k in ('taskhash', 'method', 'unihash')}
502     def query_equivalent(self, cursor, method, taskhash):  argument
505 …  'SELECT taskhash, method, unihash FROM unihashes_v2 WHERE method=:method AND taskhash=:taskhash',
507                 'method': method,
539                     method, taskhash = item
540                     await copy_unihash_from_upstream(client, self.db, method, taskhash)