class parsl.dataflow.dflow.DataFlowKernelLoader[source]

Manage which DataFlowKernel is active.

This is a singleton class containing only class methods. You should not need to instantiate this class.

__init__()[source]

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

Methods

 Initialize self. Clear the active DataFlowKernel so that a new one can be loaded. Return the currently-loaded DataFlowKernel. load([config]) Load a DataFlowKernel. Waits for all tasks in the task list to be completed, by waiting for their AppFuture to be completed.
classmethod clear()[source]

Clear the active DataFlowKernel so that a new one can be loaded.

classmethod dfk()[source]

classmethod load(config: Optional[parsl.config.Config] = None)[source]

Parameters

config (-) – Configuration to load. This config will be passed to a new DataFlowKernel instantiation which will be set as the active DataFlowKernel.

Returns

classmethod wait_for_current_tasks()[source]