rail.pipelines.degradation.truth_to_observed module

class rail.pipelines.degradation.truth_to_observed.TruthToObservedPipeline

Bases: RailPipeline

__init__(error_models=None, selectors=None, models_to_run_select=None, *, blending=False, parallel=False)

Create a MiniRunner Pipeline

In addition to parent initialization parameters (see the Pipeline base class), this subclass can take these optional keywords.

Parameters:

  • callback (function(event_type: str, event_info: dict)) – A function called when jobs launch, complete, or fail, and when the pipeline aborts. Can be used for tracing execution. Default=None.

  • sleep (function(t: float)) – A function to replace time.sleep called in the pipeline to wait until the next time to check process completion Most normal usage will not need this. Default=None.

  • error_models (dict | None)

  • selectors (dict | None)

  • models_to_run_select (list[str] | None)

  • blending (bool)

  • parallel (bool)

default_input_dict = {'input': 'dummy.in'}