![]() |
Class ComponentLauncher
Responsible for launching driver, executor and publisher of component.
Inherits From: BaseComponentLauncher
Convenient subclass when given a concrete component to launch.
__init__
__init__(
component,
pipeline_info,
driver_args,
metadata_connection_config,
additional_pipeline_args
)
Initialize a ComponentLauncher.
Args:
component
: The component to launch.pipeline_info
: An instance of data_types.PipelineInfo that holds pipeline properties.driver_args
: An instance of data_types.DriverArgs that holds component specific driver args.metadata_connection_config
: ML metadata connection config.additional_pipeline_args
: Additional pipeline args, includes,- beam_pipeline_args: Beam pipeline args for beam jobs within executor. Executor will use beam DirectRunner as Default.
Methods
launch
launch()
Execute the component, includes driver, executor and publisher.
Returns:
The execution id of the launch.