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.
DataManager.add_file
DataManager.get_data_manager
DataManager.scale_in
DataManager.scale_out
DataManager.shutdown
stage_in(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.
DataManager.start
DataManager.submit

Attributes

DataManager.run_dir
DataManager.scaling_enabled