Skip to content

Commit 1ebbbf6

Browse files
authored
Add explicit check for name not None (#9265)
1 parent deb1004 commit 1ebbbf6

2 files changed

Lines changed: 11 additions & 1 deletion

File tree

distributed/tests/test_worker.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2147,6 +2147,16 @@ def get_thread_name():
21472147
result = await c.gather(c.submit(get_thread_name, pure=False))
21482148
assert "WorkerName-Dask-Default-Threads" in result
21492149

2150+
# LocalCluster by default assigns numbers starting from zero
2151+
# as the worker names
2152+
async with Worker(
2153+
s.address,
2154+
nthreads=1,
2155+
name=0,
2156+
):
2157+
result = await c.gather(c.submit(get_thread_name, pure=False))
2158+
assert "0-Dask-Default-Threads" in result
2159+
21502160
async with Worker(
21512161
s.address,
21522162
nthreads=1,

distributed/worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -615,7 +615,7 @@ def __init__(
615615

616616
self.name = name
617617

618-
executor_pool_prefix = f"{self.name}-" if self.name else ""
618+
executor_pool_prefix = f"{self.name}-" if self.name is not None else ""
619619
# Common executors always available
620620
self.executors = {
621621
"offload": utils._offload_executor,

0 commit comments

Comments
 (0)