diff --git a/parsl/executors/globus_compute.py b/parsl/executors/globus_compute.py index d2078dfb18..189bedc18f 100644 --- a/parsl/executors/globus_compute.py +++ b/parsl/executors/globus_compute.py @@ -40,8 +40,6 @@ def __init__( self, executor: Executor, label: str = 'GlobusComputeExecutor', - resource_specification: Optional[dict] = None, - user_endpoint_config: Optional[dict] = None, ): """ Parameters @@ -54,17 +52,6 @@ def __init__( label: a label to name the executor - - resource_specification: - Specify resource requirements for individual task execution. - - user_endpoint_config: - User endpoint configuration values as described - and allowed by endpoint administrators. Must be a JSON-serializable dict - or None. Refer docs from `globus-compute - `_ - for more info. - """ if not _globus_compute_enabled: raise OptionalModuleMissing( @@ -74,8 +61,8 @@ def __init__( super().__init__() self.executor: Executor = executor - self.resource_specification = resource_specification - self.user_endpoint_config = user_endpoint_config + self.resource_specification = self.executor.resource_specification + self.user_endpoint_config = self.executor.user_endpoint_config self.label = label def start(self) -> None: diff --git a/parsl/tests/unit/test_globus_compute_executor.py b/parsl/tests/unit/test_globus_compute_executor.py index 810e3650de..b65ff92047 100644 --- a/parsl/tests/unit/test_globus_compute_executor.py +++ b/parsl/tests/unit/test_globus_compute_executor.py @@ -37,7 +37,9 @@ def test_gc_executor_label(mock_ex, randomstring): def test_gc_executor_resets_spec_after_submit(mock_ex, randomstring): submit_res = {randomstring(): "some submit res"} res = {"some": randomstring(), "spec": randomstring()} - gce = GlobusComputeExecutor(mock_ex, resource_specification=res) + mock_ex.resource_specification = res + mock_ex.user_endpoint_config = None + gce = GlobusComputeExecutor(mock_ex) fn = mock.Mock() orig_res = mock_ex.resource_specification