frex.pipelines package

Submodules

frex.pipelines.pipeline module

class frex.pipelines.pipeline.Pipeline(*, stages: Tuple[Union[frex.pipeline_stages.pipeline_stage.PipelineStage, frex.pipelines.pipeline.Pipeline], ...])[source]

Bases: object

The base Pipeline class that will run a recommendation pipeline.

Custom Pipelines should be implemented by extending this base class.

__call__(*, candidates: Optional[Generator[frex.models.candidate.Candidate, None, None]] = None, context: Optional[object] = None) → Generator[frex.models.candidate.Candidate, None, None][source]: Call self as a function.

Module contents