Fix claimWork call for taskcluster>39

escapewindow · escapewindow · commit bd69dc33810f · 2021-08-05T16:13:33.000-07:00
diff --git a/src/scriptworker/task.py b/src/scriptworker/task.py
@@ -746,6 +746,6 @@ async def claim_work(context):
         "tasks": 1,
     }
     try:
-        return await context.queue.claimWork(context.config["provisioner_id"], context.config["worker_type"], payload)
+        return await context.queue.claimWork(f"{context.config['provisioner_id']}/{context.config['worker_type']}", payload)
     except (taskcluster.exceptions.TaskclusterFailure, aiohttp.ClientError, asyncio.TimeoutError) as exc:
         log.warning("{} {}".format(exc.__class__, exc))

Original file line number	Diff line number	Diff line change
`@@ -746,6 +746,6 @@ async def claim_work(context):`
`746`	`746`	`"tasks": 1,`
`747`	`747`	`}`
`748`	`748`	`try:`
`749`		`- return await context.queue.claimWork(context.config["provisioner_id"], context.config["worker_type"], payload)`
	`749`	`+ return await context.queue.claimWork(f"{context.config['provisioner_id']}/{context.config['worker_type']}", payload)`
`750`	`750`	`except (taskcluster.exceptions.TaskclusterFailure, aiohttp.ClientError, asyncio.TimeoutError) as exc:`
`751`	`751`	`log.warning("{} {}".format(exc.__class__, exc))`