Skip to content

Commit d9cb0e9

Browse files
committed
Remvoe worker kwarg from gather_dep fetch transition
1 parent 51b2100 commit d9cb0e9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

distributed/worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2340,7 +2340,7 @@ async def gather_dep(
23402340
self.release_key(d, cause="already executing at gather")
23412341
continue
23422342
elif ts.state not in ("ready", "memory"):
2343-
self.transition(ts, "fetch", worker=worker)
2343+
self.transition(ts, "fetch")
23442344

23452345
if not busy and d not in data and ts.dependents:
23462346
self.log.append(("missing-dep", d))

0 commit comments

Comments
 (0)