From 09d7af3eb49f696bfb0a182bc236c3154a910537 Mon Sep 17 00:00:00 2001 From: Ivan Raikov Date: Tue, 27 Aug 2024 17:31:55 -0500 Subject: [PATCH] fix for spawn vs. split logic when broker function is specified --- distwq.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/distwq.py b/distwq.py index 1f1f6d1..b0dc7f9 100644 --- a/distwq.py +++ b/distwq.py @@ -1751,11 +1751,11 @@ def check_spawn_config( "distwq.run: cannot use broker_fun_name when " "spawn_workers is set to False" ) - if broker_is_worker: - raise RuntimeError( - "distwq.run: cannot use broker_fun_name when " - "broker_is_worker is set to True" - ) + if broker_is_worker: + raise RuntimeError( + "distwq.run: cannot use broker_fun_name when " + "broker_is_worker is set to True" + ) if spawn_workers and (nprocs_per_worker == 1) and broker_is_worker: raise RuntimeError( "distwq.run: cannot spawn workers when nprocs_per_worker=1 "