Skip to content

Commit 521ad41

Browse files
committed
Revert shim rewrite
1 parent 62d1281 commit 521ad41

File tree

1 file changed

+8
-16
lines changed

1 file changed

+8
-16
lines changed

hstest/common/process_utils.py

Lines changed: 8 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -29,22 +29,14 @@ def weakref_cb(_, q=self._work_queue) -> None:
2929
if num_threads < self._max_workers:
3030
thread_name = "%s_%d" % (self._thread_name_prefix or self, num_threads)
3131

32-
# Python 3.14+ refactored initializer/initargs into WorkerContext
33-
if hasattr(self, "_create_worker_context"):
34-
args = (
35-
weakref.ref(self, weakref_cb),
36-
self._create_worker_context(),
37-
self._work_queue,
38-
)
39-
else:
40-
args = (
41-
weakref.ref(self, weakref_cb),
42-
self._work_queue,
43-
self._initializer,
44-
self._initargs,
45-
)
46-
47-
t = threading.Thread(name=thread_name, target=_worker, args=args)
32+
args = (
33+
weakref.ref(self, weakref_cb),
34+
self._work_queue,
35+
self._initializer,
36+
self._initargs,
37+
)
38+
39+
t = threading.Thread(name=thread_name, target=_worker, args=args, group=self.group)
4840
t.daemon = True
4941
t.start()
5042
self._threads.add(t)

0 commit comments

Comments
 (0)