def create_run(instance, **kwargs):
    with get_foo_pipeline_handle() as pipeline_handle:
        create_run_for_test(instance, external_pipeline_origin=pipeline_handle.get_external_origin(), pipeline_name='foo', **kwargs)
def create_run(instance, **kwargs):
    with get_foo_pipeline_handle() as pipeline_handle:
        create_run_for_test(instance, external_pipeline_origin=pipeline_handle.get_external_origin(), pipeline_name='foo', **kwargs)