def compile_and_run_pipeline(client, experiment_id, pipeline_definition, input_params, output_file_dir, pipeline_name):
    pipeline_path = os.path.join(output_file_dir, pipeline_name)
    utils.run_command(f'dsl-compile --py {pipeline_definition} --output {pipeline_path}.yaml')
    run = client.run_pipeline(experiment_id, pipeline_name, f'{pipeline_path}.yaml', input_params)
    return run.id
def compile_and_run_pipeline(client, experiment_id, pipeline_definition, input_params, output_file_dir, pipeline_name):
    pipeline_path = os.path.join(output_file_dir, pipeline_name)
    utils.run_command(f'dsl-compile --py {pipeline_definition} --output {pipeline_path}.yaml')
    run = client.run_pipeline(experiment_id, pipeline_name, f'{pipeline_path}.yaml', input_params)
    return run.id