def execute_pipeline_iterator(pipeline, environment_dict=None, run_config=None):
    '''Returns iterator that yields :py:class:`SolidExecutionResult` for each
    solid executed in the pipeline.

    This is intended to allow the caller to do things between each executed
    node. For the 'synchronous' API, see :py:func:`execute_pipeline`.

    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:
      Iterator[DagsterEvent]
    '''
    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:
        return _execute_pipeline_iterator(pipeline_context)
def execute_pipeline_iterator(pipeline, environment_dict=None, run_config=None):
    '''Returns iterator that yields :py:class:`SolidExecutionResult` for each
    solid executed in the pipeline.

    This is intended to allow the caller to do things between each executed
    node. For the 'synchronous' API, see :py:func:`execute_pipeline`.

    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:
      Iterator[DagsterEvent]
    '''
    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:
        return _execute_pipeline_iterator(pipeline_context)
def execute_pipeline_iterator ( 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 : return _execute_pipeline_iterator ( pipeline_context )
Returns iterator that yields :py:class:`SolidExecutionResult` for each
    solid executed in the pipeline.

    This is intended to allow the caller to do things between each executed
    node. For the 'synchronous' API, see :py:func:`execute_pipeline`.

    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:
      Iterator[DagsterEvent]
Returns iterator that yields : py : class : SolidExecutionResult for each solid executed in the pipeline .