From 0eaaebff417bc52752faf47806dd7f2cd329d04a Mon Sep 17 00:00:00 2001 From: Jan Janssen Date: Tue, 16 Apr 2024 16:56:08 -0500 Subject: [PATCH] Remove execute_parallel_tasks_loop() --- pympipool/shared/executorbase.py | 17 ++++------------- 1 file changed, 4 insertions(+), 13 deletions(-) diff --git a/pympipool/shared/executorbase.py b/pympipool/shared/executorbase.py index d5273385..e432070b 100644 --- a/pympipool/shared/executorbase.py +++ b/pympipool/shared/executorbase.py @@ -190,20 +190,11 @@ def execute_parallel_tasks( this look up for security reasons. So on MacOS it is required to set this option to true """ - execute_parallel_tasks_loop( - interface=interface_bootup( - command_lst=_get_backend_path(cores=cores), - connections=interface_class(cores=cores, **kwargs), - hostname_localhost=hostname_localhost, - ), - future_queue=future_queue, - init_function=init_function, + interface = interface_bootup( + command_lst=_get_backend_path(cores=cores), + connections=interface_class(cores=cores, **kwargs), + hostname_localhost=hostname_localhost, ) - - -def execute_parallel_tasks_loop( - interface, future_queue: queue.Queue, init_function: Optional[callable] = None -): if init_function is not None: interface.send_dict( input_dict={"init": True, "fn": init_function, "args": (), "kwargs": {}}