Lines Matching refs:patch_obj

191 def append_jobs(patch_obj, src, git_ref, now=None):  argument
206     patch_obj['jobs/' + job_id] = {
213     patch_obj['jobs_queued/' + job_id] = 0
214     patch_obj[src]['jobs'][job_id] = 0
251   patch_obj = {}
252   patch_obj['cls_pending/%s-%s' % (cl, patchset)] = 0
253   patch_obj[src] = {
260   append_jobs(patch_obj, src, ref)
262   await req_async('PATCH', DB + '.json', body=patch_obj)
324   patch_obj = {
328   await req_async('PATCH', '%s.json' % DB, body=patch_obj)
432   patch_obj = {
443   append_jobs(patch_obj, src, ref, now)
444   await req_async('PATCH', DB + '.json', body=patch_obj)
483   patch_obj = {}
488       patch_obj['workers/' + worker_id] = {}  # DELETE
489   if len(patch_obj) == 0:
491   logging.info('Purging %d inactive workers', len(patch_obj))
492   await req_async('PATCH', DB + '.json', body=patch_obj)
501   patch_obj = {
506     patch_obj['jobs/%s/status' % job_id] = 'CANCELLED'
507     patch_obj['jobs/%s/time_ended' % job_id] = utc_now_iso()
508   await req_async('PATCH', DB + '.json', body=patch_obj)
514   patch_obj = {
523   await req_async('PATCH', DB + '.json', body=patch_obj)