From 4d97f703c703d728c4014da8f58afc02d1ab05a2 Mon Sep 17 00:00:00 2001 From: noelppp <151667316+noelppp@users.noreply.github.com> Date: Wed, 12 Feb 2025 08:12:56 +0100 Subject: [PATCH 1/3] Update globus_compute.py Add two arguments `storage_access` and `working_dir`. --- parsl/executors/globus_compute.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/parsl/executors/globus_compute.py b/parsl/executors/globus_compute.py index 687026979d..4aa7b9d658 100644 --- a/parsl/executors/globus_compute.py +++ b/parsl/executors/globus_compute.py @@ -2,10 +2,11 @@ import copy from concurrent.futures import Future -from typing import Any, Callable, Dict +from typing import Any, Callable, Dict, List, Optional import typeguard +from parsl.data_provider.staging import Staging from parsl.errors import OptionalModuleMissing from parsl.executors.base import ParslExecutor from parsl.utils import RepresentationMixin @@ -40,6 +41,8 @@ def __init__( self, executor: Executor, label: str = 'GlobusComputeExecutor', + storage_access: Optional[List[Staging]] = None, + working_dir: Optional[str] = None, ): """ Parameters @@ -64,7 +67,9 @@ def __init__( self.resource_specification = self.executor.resource_specification self.user_endpoint_config = self.executor.user_endpoint_config self.label = label - + self.storage_access = storage_access + self.working_dir = working_dir + def start(self) -> None: """ Start the Globus Compute Executor """ pass From f989a13d780ffc702715dbdaaad37011b16f676e Mon Sep 17 00:00:00 2001 From: noelppp <151667316+noelppp@users.noreply.github.com> Date: Thu, 20 Feb 2025 07:59:28 +0100 Subject: [PATCH 2/3] Update globus_compute.py documentation --- parsl/executors/globus_compute.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/parsl/executors/globus_compute.py b/parsl/executors/globus_compute.py index 4aa7b9d658..305d09a41a 100644 --- a/parsl/executors/globus_compute.py +++ b/parsl/executors/globus_compute.py @@ -55,6 +55,12 @@ def __init__( label: a label to name the executor + + storage_access: + a list of staging providers that will be used for file staging + + working_dir: + The working dir to be used for file staging """ if not _globus_compute_enabled: raise OptionalModuleMissing( From 2f2bbe2f18c025268c01e2d8bb13171d97e72184 Mon Sep 17 00:00:00 2001 From: noelppp <151667316+noelppp@users.noreply.github.com> Date: Thu, 20 Feb 2025 08:19:57 +0100 Subject: [PATCH 3/3] Remove whitespace on blank lines --- parsl/executors/globus_compute.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/parsl/executors/globus_compute.py b/parsl/executors/globus_compute.py index 305d09a41a..2b4d50e1d0 100644 --- a/parsl/executors/globus_compute.py +++ b/parsl/executors/globus_compute.py @@ -58,7 +58,7 @@ def __init__( storage_access: a list of staging providers that will be used for file staging - + working_dir: The working dir to be used for file staging """ @@ -75,7 +75,7 @@ def __init__( self.label = label self.storage_access = storage_access self.working_dir = working_dir - + def start(self) -> None: """ Start the Globus Compute Executor """ pass