poprox_recommender.lkpipeline.runner

Pipeline runner logic.

Classes

DeferredRun(runner, iname, cname, node, ...)	Implementation of Lazy for deferred runs in a pipeline runner.
PipelineRunner(pipe, inputs)	Node status and results for a single pipeline run.

class poprox_recommender.lkpipeline.runner.PipelineRunner(pipe, inputs)

Bases: object

Node status and results for a single pipeline run.

This class operates recursively; pipelines should never be so deep that recursion fails.

Parameters:

• pipe (Pipeline)

• inputs (dict[str, Any])

run(node, *, required=True)

Run the pipleline to obtain the results of a node.

Parameters:

• node (Node[Any])

• required (bool)

Return type:

Any

class poprox_recommender.lkpipeline.runner.DeferredRun(runner, iname, cname, node, required, data_type)

Bases: Generic[T]

Implementation of Lazy for deferred runs in a pipeline runner.

Parameters:

• runner (PipelineRunner)

• iname (str)

• cname (str)

• node (Node[T])

• required (bool)

• data_type (type | None)