python_modules/dagster/dagster/core/execution.py
def execute_pipeline(pipeline, environment_dict=None, run_config=None):
    '''
    "Synchronous" version of :py:func:`execute_pipeline_iterator`.

    Note: raise_on_error is very useful in testing contexts when not testing for error
    conditions

    Parameters:
      pipeline (PipelineDefinition): Pipeline to run
      environment_dict (dict): The enviroment configuration that parameterizes this run
      run_config (RunConfig): Configuration for how this pipeline will be executed

    Returns:
      :py:class:`PipelineExecutionResult`
    '''

    check.inst_param(pipeline, 'pipeline', PipelineDefinition)
    environment_dict = check.opt_dict_param(environment_dict, 'environment_dict')
    run_config = check_run_config_param(run_config)
    environment_config = create_environment_config(pipeline, environment_dict)
    intermediates_manager = construct_intermediates_manager(
        run_config, environment_config, pipeline
    )

    with _pipeline_execution_context_manager(
        pipeline, environment_config, run_config, intermediates_manager
    ) as pipeline_context:
        event_list = list(_execute_pipeline_iterator(pipeline_context))

    return PipelineExecutionResult(
        pipeline,
        run_config.run_id,
        event_list,
        lambda: _pipeline_execution_context_manager(
            pipeline, environment_config, run_config, intermediates_manager
        ),
    )
def execute_pipeline(pipeline, environment_dict=None, run_config=None):
    '''
    "Synchronous" version of :py:func:`execute_pipeline_iterator`.

    Note: raise_on_error is very useful in testing contexts when not testing for error
    conditions

    Parameters:
      pipeline (PipelineDefinition): Pipeline to run
      environment_dict (dict): The enviroment configuration that parameterizes this run
      run_config (RunConfig): Configuration for how this pipeline will be executed

    Returns:
      :py:class:`PipelineExecutionResult`
    '''

    check.inst_param(pipeline, 'pipeline', PipelineDefinition)
    environment_dict = check.opt_dict_param(environment_dict, 'environment_dict')
    run_config = check_run_config_param(run_config)
    environment_config = create_environment_config(pipeline, environment_dict)
    intermediates_manager = construct_intermediates_manager(
        run_config, environment_config, pipeline
    )

    with _pipeline_execution_context_manager(
        pipeline, environment_config, run_config, intermediates_manager
    ) as pipeline_context:
        event_list = list(_execute_pipeline_iterator(pipeline_context))

    return PipelineExecutionResult(
        pipeline,
        run_config.run_id,
        event_list,
        lambda: _pipeline_execution_context_manager(
            pipeline, environment_config, run_config, intermediates_manager
        ),
    )
"Synchronous" version of :py:func:`execute_pipeline_iterator`.

    Note: raise_on_error is very useful in testing contexts when not testing for error
    conditions

    Parameters:
      pipeline (PipelineDefinition): Pipeline to run
      environment_dict (dict): The enviroment configuration that parameterizes this run
      run_config (RunConfig): Configuration for how this pipeline will be executed

    Returns:
      :py:class:`PipelineExecutionResult`