cars.pipelines.pipeline_template

This module contains class pipeline template for templating the pipeline concept.

Module Contents

Classes

PipelineTemplate

Class for general specification of an pipeline

Functions

_merge_pipeline_conf_rec(conf1, conf2)

Merge secondary configuration on primary one
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

merge_pipeline_conf(config1, config2)[source]

Merge two pipeline dict, generating a new configuration

Parameters

  • conf1 (dict) – configuration

  • conf2 (dict) – configuration

Returns

merged conf

Return type

dict

abstract check_inputs(conf, config_json_dir=None)[source]

Check the inputs given

Parameters

  • conf (dict) – configuration of inputs

  • config_json_dir (str) – directory of used json, if user filled paths with relative paths

Returns

overloader inputs

Return type

dict

abstract check_output(conf, pipeline)[source]

Check the output given

Parameters

  • conf (dict) – configuration of output

  • pipeline – name of corresponding pipeline

:return overloader output :rtype : dict

abstract check_applications(conf)[source]

Check the given configuration for applications

Parameters

conf (dict) – configuration of applications

abstract run()[source]

Run pipeline

cars.pipelines.pipeline_template._merge_pipeline_conf_rec(conf1, conf2)[source]

Merge secondary configuration on primary one

Parameters

  • conf1 (dict) – configuration

  • conf2 (dict) – configuration

Returns

merged conf

Return type

dict