ess.reduce.live.workflow.LiveWorkflow#

class ess.reduce.live.workflow.LiveWorkflow(*, streamed, outputs)[source]#

A workflow class that fulfills Beamlime’s LiveWorkflow protocol.

__init__(*, streamed, outputs)[source]#

Methods

__init__(*, streamed, outputs)

from_workflow(*, workflow, accumulators, ...)

Create a live workflow from a base workflow and other parameters.
classmethod from_workflow(*, workflow, accumulators, outputs, run_type, nexus_filename)[source]#

Create a live workflow from a base workflow and other parameters.

Parameters:

  • workflow (Pipeline) – Base workflow to use for live data reduction.

  • accumulators (dict[type, Accumulator]) – Accumulators forwarded to the stream processor.

  • outputs (dict[str, type]) – Mapping from output names to keys in the workflow. The keys correspond to workflow results that will be computed.

  • run_type (type[TypeVar(RunType)]) – Type of the run to process. This defines which run is the dynamic run being processed. The NeXus template file will be set as the filename for this run.

  • nexus_filename (Path) – Path to the NeXus file to process.

Returns:

TypeVar(T, bound= LiveWorkflow) – Live workflow object.