Step

The otter.step package contains the step model and all the mechanics for the parallel execution of tasks.

model module

Step module.

class otter.step.model.Step(name: str, specs: list[Spec], task_registry: TaskRegistry, config: Config)[source]

Bases: StepReporter

Step class.

This class represents a step in the pipeline.

run() Step[source]

Run the step.

step_reporter module

StepReporter class and report decorator for logging and updating steps in the manifest.

class otter.step.step_reporter.StepReporter(name: str)[source]

Bases: object

Class for logging and updating steps in the manifest.

start_run() None[source]

Update a step that has started running.

finish_validation() None[source]

Update a step that has finished validation.

fail() None[source]

Update a step that has failed running or validation.

upsert_task_manifests(result: Sequence[TaskReporter]) None[source]

Update the step manifest with new task manifests.

Module contents

Step module.