rail.pipelines.degradation.apply_phot_errors module

class rail.pipelines.degradation.apply_phot_errors.ApplyPhotErrorsPipeline

Bases: RailPipeline

__init__(error_models=None, *, 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)

  • parallel (bool)

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