|View source on GitHub|
Responsible for launching driver, executor and publisher of component.
Convenient subclass when given a concrete component to launch.
__init__( component, pipeline_info, driver_args, metadata_connection_config, additional_pipeline_args )
Initialize a ComponentLauncher.
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.
Execute the component, includes driver, executor and publisher.
The execution id of the launch.