# parsl.data_provider.data_manager.DataManager¶

class parsl.data_provider.data_manager.DataManager(dfk: DataFlowKernel)[source]

The DataManager is responsible for transferring input and output data.

__init__(dfk: DataFlowKernel)None[source]

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.