Skip to content

Commit 90ae385

Browse files
committed
Start worker thread number at 1
This number is only for human consumption and startng at 1 seems more user friendly to me.
1 parent af3526e commit 90ae385

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

spinach/worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ def __init__(self, num_workers: int, namespace: str):
4444
self._must_stop = threading.Event()
4545
self.poison_pill = object()
4646

47-
for i in range(num_workers):
47+
for i in range(1, num_workers + 1):
4848
thread = threading.Thread(
4949
target=self._worker_func,
5050
name='{}-worker-{}'.format(self._namespace, i)

tests/test_worker.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -136,10 +136,10 @@ def test_worker_signals(job):
136136
mock_job_started_receiver.assert_called_once_with(ns, job=ANY)
137137
mock_job_finished_receiver.assert_called_once_with(ns, job=ANY)
138138
mock_worker_started_receiver.assert_called_once_with(
139-
ns, worker_name='tests-worker-0'
139+
ns, worker_name='tests-worker-1'
140140
)
141141
mock_worker_terminated_receiver.assert_called_once_with(
142-
ns, worker_name='tests-worker-0'
142+
ns, worker_name='tests-worker-1'
143143
)
144144

145145

0 commit comments

Comments
 (0)