Skip to content

kiara.events

PipelineInputEvent pydantic-model

Event that gets fired when one or several inputs for the pipeline itself have changed.

updated_pipeline_inputs: List[str] pydantic-field required

list of pipeline input names that where changed

PipelineOutputEvent pydantic-model

Event that gets fired when one or several outputs for the pipeline itself have changed.

updated_pipeline_outputs: List[str] pydantic-field required

list of pipeline output names that where changed

StepEvent pydantic-model

__repr__(self) special

Return repr(self).

Source code in kiara/events.py 
def __repr__(self):
    d = self.dict()
    d.pop("pipeline_id")
    return f"{self.__class__.__name__}(pipeline_id={self.pipeline_id} data={d}"

__str__(self) special

Return str(self).

Source code in kiara/events.py 
def __str__(self):
    return self.__repr__()

StepInputEvent pydantic-model

Event that gets fired when one or several inputs for steps within a pipeline have changed.

newly_stale_steps: List[str] property readonly

Convenience method to display the steps that have been rendered 'stale' by this event.

updated_step_inputs: Dict[str, List[str]] pydantic-field required

steps (keys) with updated inputs which need re-processing (value is list of updated input names)

StepOutputEvent pydantic-model

Event that gets fired when one or several outputs for steps within a pipeline have changed.

updated_step_outputs: Dict[str, List[str]] pydantic-field required

steps (keys) that finished processing of one, several or all outputs (values are list of 'finished' output fields)