gfw.common.beam.pipeline.PipelineFactory#

class PipelineFactory(config, dag_factory, **kwargs)[source]#

Builds a Pipeline instance from PipelineConfig and DagFactory.

Parameters:

config (PipelineConfig) – Configuration for the pipeline.
dag_factory (DagFactory) – Factory that produces the pipeline’s Dag.
**kwargs (Any) – Any additional parameters to be passed to Pipeline constructor.

Methods

build_pipeline

Constructs and returns a fully configured Pipeline instance.

build_pipeline()[source]#

Constructs and returns a fully configured Pipeline instance.

Returns:: A pipeline with DAG, version, name, and CLI arguments.
Return type:: Pipeline