diff --git a/parsl/executors/taskvine/exec_parsl_function.py b/parsl/executors/taskvine/exec_parsl_function.py index dbef5859dc..59cca96bab 100644 --- a/parsl/executors/taskvine/exec_parsl_function.py +++ b/parsl/executors/taskvine/exec_parsl_function.py @@ -125,7 +125,7 @@ def load_function(map_file, function_file, argument_file): mapping = unpack_object_from_file(map_file) remap_all_files(mapping, fn_args, fn_kwargs) - + # Create the namespace to isolate the function execution. user_ns = locals() user_ns.update({'__builtins__': __builtins__}) diff --git a/parsl/executors/taskvine/executor.py b/parsl/executors/taskvine/executor.py index c78740626f..a6ce3987bc 100644 --- a/parsl/executors/taskvine/executor.py +++ b/parsl/executors/taskvine/executor.py @@ -11,13 +11,11 @@ import hashlib import subprocess import os -import pickle import queue import inspect import shutil import itertools import uuid -from ctypes import c_bool from concurrent.futures import Future from typing import List, Optional, Union, Literal @@ -78,7 +76,7 @@ class TaskVineExecutor(BlockProviderExecutor, putils.RepresentationMixin): Default is 'factory'. function_exec_mode: Union[Literal['regular'], Literal['serverless']] - Choose to execute functions with a regular fresh python process or a + Choose to execute functions with a regular fresh python process or a pre-warmed forked python process. Default is 'regular'. diff --git a/parsl/executors/taskvine/factory.py b/parsl/executors/taskvine/factory.py index 18bc969be7..24f74f3fe3 100644 --- a/parsl/executors/taskvine/factory.py +++ b/parsl/executors/taskvine/factory.py @@ -1,5 +1,4 @@ import logging -import time from parsl.process_loggers import wrap_with_logs from parsl.executors.taskvine.errors import TaskVineFactoryFailure