tketool.pipeline

Small stage-based processing pipelines with ordered decorators, optional parallel item processing, and local buffering.

pip install tketool.pipeline

from enum import Enum

from tketool.pipeline import Pipeline, invoke_all


class Stage(Enum):
    PREPARE = "prepare"
    RUN = "run"


class Steps:
    @invoke_all(Stage.PREPARE.value, priority=10)
    def prepare(self, board):
        board.current_data = {"ready": True}


pipeline = Pipeline(Stage, acts=[Steps()])
result = pipeline()

The retired tketool.injections path is not shipped.