parsl.data_provider.data_manager.DataManager

class parsl.data_provider.data_manager.DataManager(dfk: DataFlowKernel)

The DataManager is responsible for transferring input and output data.

__init__(dfk: DataFlowKernel) → None

Initialize the DataManager.

Parameters

dfk (-) – The DataFlowKernel that this DataManager is managing data for.

Methods

__init__(dfk)	Initialize the DataManager.
optionally_stage_in(input, func, executor)
replace_task(file, func, executor)	This will give staging providers the chance to wrap (or replace entirely!) the task function.
replace_task_stage_out(file, func, executor)	This will give staging providers the chance to wrap (or replace entirely!) the task function.
stage_in(file, input, executor)	Transport the input from the input source to the executor, if it is file-like, returning a DataFuture that wraps the stage-in operation.
stage_out(file, executor, app_fu)	Transport the file from the local filesystem to the remote Globus endpoint.