cars.pipelines.merging.merging

CARS merging pipeline class file

Attributes

PIPELINE

Classes

MergingPipeline

Merging pipeline

Module Contents

cars.pipelines.merging.merging.PIPELINE = 'merging'
class cars.pipelines.merging.merging.MergingPipeline(conf, config_dir=None)[source]

Bases: cars.pipelines.pipeline_template.PipelineTemplate

Merging pipeline

setup_progress_tracking(parent_pipeline_id=None)[source]

Setup progress tracking for merging.

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

used_conf
metadata = None
out_dir
dump_dir
save_all_intermediate_data
pipeline_progress_id = None
task_progress_id = None
check_pipeline_conf(conf)[source]

Check pipeline configuration

static check_inputs(conf, config_dir=None)[source]

Check the inputs given

Parameters:

  • conf (dict) – configuration of inputs

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

Returns:

overloaded inputs

Return type:

dict

static check_advanced_parameters(conf)[source]

Check the advanced parameters consistency

Parameters:

  • conf (dict) – configuration of inputs

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

Returns:

overloaded inputs

Return type:

dict

static check_output(conf)[source]

Check the output given

Parameters:

conf (dict) – configuration of output

Returns:

overloader output

Return type:

dict

check_applications(conf)[source]

Check the given configuration for applications, and generates needed applications for pipeline.

Parameters:

conf (dict) – configuration of applications

run(args=None, log_dir=None, parent_pipeline_id=None)[source]

Run pipeline