Module wallaroo.pipeline
Classes
class Pipeline (client: gql.client.Client)-
Methods
def create_pipeline(self, pipeline_id: str, version: str, definition: PipelineConfig)-
Create a pipeline with the specifed name, version and configuration.
def create_pipeline_version(self, pipeline_pk_id: int, version: str, definition: PipelineConfig)def get_pipeline(self, pipeline_id: str) ‑> Optional[dict]-
Gets the details for a particular pipeline. Returns None if no pipeline with that pipeline_id is found.
def get_pipelines(self) ‑> List[dict]
class PipelineConfig (pipeline_id: str, steps: Iterable[StepConfig])-
Subclasses
Methods
def to_definition(self)
class StepConfig (operation: str, id: str, args: Iterable[str])-
Methods
def to_definition(self)
class ValueSplitExperiment (pipeline_id, meta_key: str, default_model: str, challenger_models: Iterable[Tuple[str, str]])-
Helper class to correctly create a value split experiment pipeline. example use: vse = ValueSplitExperiment(experiment_name, meta_key_name, default_model_name, [('gold', model_a_name), ('platinum', model_b_name)])
Ancestors