cars.pipelines.pipeline_template
This module contains class pipeline template for templating the pipeline concept.
Classes
Class for general specification of an pipeline |
Functions
|
Merge secondary configuration on primary one |
Module Contents
- class cars.pipelines.pipeline_template.PipelineTemplate[source]
Class for general specification of an pipeline
- check_orchestrator(conf)[source]
Check the configuration of orchestrator
- Parameters:
conf (dict) – configuration of orchestrator
- Returns:
overloaded orchestrator conf
- Return type:
dict
- check_global_schema(conf)[source]
Check the given global configuration
- Parameters:
conf (dict) – configuration
- abstract check_inputs(conf, config_dir=None)[source]
Check the inputs given
- Parameters:
conf (dict) – configuration of inputs
config_dir (str) – directory of used json, if user filled paths with relative paths
- Returns:
overloader inputs
- Return type:
dict
- abstract check_output(conf)[source]
Check the output given
- Parameters:
conf (dict) – configuration of output
:return overloader output :rtype : dict
- abstract setup_progress_tracking(parent_pipeline_id=None)[source]
Setup progress tracking for this pipeline.
Concrete pipelines define their own task structure and registration.
- Parameters:
parent_pipeline_id (int or None) – Optional parent pipeline ID
- Returns:
Task ID to pass to orchestrator via set_target_task()
- Return type:
int