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
        ),
    )
def execute_pipeline ( pipeline , environment_dict = None , run_config = None ) : 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`
Synchronous version of : py : func : execute_pipeline_iterator .