From 9f7242d118316c27720f61eee6fddb9564df9374 Mon Sep 17 00:00:00 2001 From: dachengx Date: Wed, 16 Oct 2024 16:04:58 -0500 Subject: [PATCH] Only use `ThreadedMailboxProcessor` when `allow_multiprocess=True` --- tests/test_1T_plugins.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/tests/test_1T_plugins.py b/tests/test_1T_plugins.py index 154b845da..7f44ff7de 100644 --- a/tests/test_1T_plugins.py +++ b/tests/test_1T_plugins.py @@ -30,9 +30,15 @@ def _run_plugins(st, make_all=False, run_id=test_run_id_1T, **process_kwargs): if not make_all: return - end_targets = set(st._get_end_targets(st._plugin_class_registry)) + end_targets = tuple(set(st._get_end_targets(st._plugin_class_registry))) if st.context_config["allow_multiprocess"]: - st.make(run_id, list(end_targets), allow_multiple=True, **process_kwargs) + st.make( + run_id, + end_targets, + allow_multiple=True, + processor="threaded_mailbox", + **process_kwargs, + ) else: for data_type in end_targets: st.make(run_id, data_type)