parsl.data_provider.globus.GlobusStaging

class parsl.data_provider.globus.GlobusStaging(endpoint_uuid: str, endpoint_path: Optional[str] = None, local_path: Optional[str] = None)[source]

Specification for accessing data on a remote executor via Globus.

Parameters:
  • endpoint_uuid (str) – Universally unique identifier of the Globus endpoint at which the data can be accessed. This can be found in the Manage Endpoints page.
  • endpoint_path (str, optional) – FIXME
  • local_path (str, optional) – FIXME
__init__(endpoint_uuid: str, endpoint_path: Optional[str] = None, local_path: Optional[str] = None)[source]

Initialize self. See help(type(self)) for accurate signature.

Methods

__init__(endpoint_uuid, endpoint_path, …) Initialize self.
can_stage_in(file) Given a File object, decide if this staging provider can stage the file.
can_stage_out(file) Like can_stage_in, but for staging out.
initialize_globus()
replace_task(dm, executor, file, func) For a file to be staged in, optionally return a replacement app function, which usually should be the original app function wrapped in staging code.
replace_task_stage_out(dm, executor, file, func) For a file to be staged out, optionally return a replacement app function, which usually should be the original app function wrapped in staging code.
stage_in(dm, executor, file, parent_fut) This call gives the staging provider an opportunity to prepare for stage-in and to launch arbitrary tasks which must complete as part of stage-in.
stage_out(dm, executor, file, app_fu) This call gives the staging provider an opportunity to prepare for stage-out and to launch arbitrary tasks which must complete as part of stage-out.