Skip to content

Commit 1b92553

Browse files
authored
Fix regression in dashboard after #7586 (#7683)
1 parent 1df643b commit 1b92553

File tree

2 files changed

+23
-1
lines changed

2 files changed

+23
-1
lines changed

distributed/tests/test_worker.py

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3755,3 +3755,25 @@ async def test_offload_getdata(c, s, a, b):
37553755
x = c.submit(EnsureOffloaded, threading.get_ident(), key="x", workers=[a.address])
37563756
y = c.submit(lambda x: None, x, key="y", workers=[b.address])
37573757
await y
3758+
3759+
3760+
@gen_cluster(client=True)
3761+
async def test_startstops(c, s, a, b):
3762+
t0 = time()
3763+
x = c.submit(inc, 1, key="x", workers=[a.address])
3764+
y = c.submit(inc, x, key="y", workers=[b.address])
3765+
await wait(y)
3766+
t1 = time()
3767+
ss = b.state.tasks["y"].startstops
3768+
assert len(ss) == 2
3769+
assert ss[0]["action"] == "transfer"
3770+
assert ss[0]["source"] == a.address
3771+
assert ss[1]["action"] == "compute"
3772+
assert (
3773+
t0 + b.scheduler_delay
3774+
< ss[0]["start"]
3775+
< ss[0]["stop"]
3776+
< ss[1]["start"]
3777+
< ss[1]["stop"]
3778+
< t1 + b.scheduler_delay
3779+
)

distributed/worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2059,7 +2059,7 @@ async def gather_dep(
20592059
logger.debug("Request %d keys from %s", len(to_gather), worker)
20602060

20612061
try:
2062-
with context_meter.meter("network") as m:
2062+
with context_meter.meter("network", func=time) as m:
20632063
response = await get_data_from_worker(
20642064
rpc=self.rpc, keys=to_gather, worker=worker, who=self.address
20652065
)

0 commit comments

Comments
 (0)