def create_pipeline() -> pipeline_pb2.Pipeline:
    'Creates an async pipeline for testing.'
    example_gen = _example_gen().with_id('my_example_gen')
    transform = _transform(examples=example_gen.outputs['examples'], a_param=10).with_id('my_transform')
    trainer = _trainer(examples=example_gen.outputs['examples'], transform_graph=transform.outputs['transform_graph']).with_id('my_trainer')
    pipeline = pipeline_lib.Pipeline(pipeline_name='my_pipeline', pipeline_root='/path/to/root', components=[example_gen, transform, trainer], execution_mode=pipeline_lib.ExecutionMode.ASYNC)
    dsl_compiler = compiler.Compiler()
    compiled_pipeline: pipeline_pb2.Pipeline = dsl_compiler.compile(pipeline)
    trainer = compiled_pipeline.nodes[2].pipeline_node
    assert (trainer.node_info.id == 'my_trainer')
    for value in trainer.inputs.inputs.values():
        value.min_count = 1
    return compiled_pipeline
Creates an async pipeline for testing.
def create_pipeline() -> pipeline_pb2.Pipeline:
    
    example_gen = _example_gen().with_id('my_example_gen')
    transform = _transform(examples=example_gen.outputs['examples'], a_param=10).with_id('my_transform')
    trainer = _trainer(examples=example_gen.outputs['examples'], transform_graph=transform.outputs['transform_graph']).with_id('my_trainer')
    pipeline = pipeline_lib.Pipeline(pipeline_name='my_pipeline', pipeline_root='/path/to/root', components=[example_gen, transform, trainer], execution_mode=pipeline_lib.ExecutionMode.ASYNC)
    dsl_compiler = compiler.Compiler()
    compiled_pipeline: pipeline_pb2.Pipeline = dsl_compiler.compile(pipeline)
    trainer = compiled_pipeline.nodes[2].pipeline_node
    assert (trainer.node_info.id == 'my_trainer')
    for value in trainer.inputs.inputs.values():
        value.min_count = 1
    return compiled_pipeline