Skip to content

Commit

Permalink
Minor variable renaming
Browse files Browse the repository at this point in the history
  • Loading branch information
yadudoc committed Nov 18, 2024
1 parent 9cbc491 commit 04b5c02
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions parsl/executors/globus_compute.py
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ def __init__(
)

super().__init__()
self._executor: Executor = executor
self.executor: Executor = executor
self.resource_specification = resource_specification
self.user_endpoint_config = user_endpoint_config
self.label = label
Expand Down Expand Up @@ -119,14 +119,14 @@ def submit(self, func: Callable, resource_specification: Dict[str, Any], *args:
else:
user_endpoint_config = self.user_endpoint_config

self._executor.resource_specification = res_spec
self._executor.user_endpoint_config = user_endpoint_config
return self._executor.submit(func, *args, **kwargs)
self.executor.resource_specification = res_spec
self.executor.user_endpoint_config = user_endpoint_config
return self.executor.submit(func, *args, **kwargs)

def shutdown(self):
"""Clean-up the resources associated with the Executor.
GCE.shutdown will cancel all futures that have not yet registered with
Globus Compute and will not wait for the launched futures to complete.
"""
self._executor.shutdown(wait=False, cancel_futures=True)
self.executor.shutdown(wait=False, cancel_futures=True)

0 comments on commit 04b5c02

Please sign in to comment.