class_docstr: An executor that executes SageMaker Pipelines locally.
class_docstr_tok: ["An","executor","that","executes","SageMaker","Pipelines","locally","."]
docstr: Initialize StepExecutor.
  
  Args:
      sagemaker_session (sagemaker.session.Session): a session to use to read configurations
          from, and use its boto client.
docstr_tok: ["Initialize","StepExecutor",".","Args",":","sagemaker_session","(","sagemaker.session.Session",")",":","a","session","to","use","to","read","configurations","from",",","and","use","its","boto","client","."]
code: def __init__(self, execution, sagemaker_session):
      """Initialize StepExecutor.
  
      Args:
          sagemaker_session (sagemaker.session.Session): a session to use to read configurations
              from, and use its boto client.
      """
      self.sagemaker_session = sagemaker_session
      self.execution = execution
      self.pipeline_dag = PipelineGraph.from_pipeline(
          self.execution.pipeline
      )
      self.local_sagemaker_client = (
          self.sagemaker_session.sagemaker_client
      )
      self._blocked_steps = set()
      self._step_executor_factory = _StepExecutorFactory(self)
  
imports: from __future__ import absolute_import
  from abc import ABC, abstractmethod
  import json
  from datetime import datetime
  from typing import Dict, List, Union
  from botocore.exceptions import ClientError
  from sagemaker.workflow.conditions import ConditionTypeEnum
  from sagemaker.workflow.function_step import DelayedReturn
  from sagemaker.workflow.steps import StepTypeEnum, Step
  from sagemaker.workflow.step_collections import StepCollection
  from sagemaker.workflow.entities import PipelineVariable
  from sagemaker.workflow.parameters import Parameter
  from sagemaker.workflow.functions import Join, JsonGet, PropertyFile
  from sagemaker.workflow.properties import Properties
  from sagemaker.workflow.execution_variables import ExecutionVariable, ExecutionVariables
  from sagemaker.workflow.pipeline import PipelineGraph
  from sagemaker.local.exceptions import StepExecutionException
  from sagemaker.local.utils import get_using_dot_notation
  from sagemaker.utils import unique_name_from_base
  from sagemaker.s3 import parse_s3_url, s3_path_join
label_desc: Use image node_id 1 to create a new LocalPipelineExecutor object from inherited base classes: object with example: obj = LocalPipelineExecutor(execution, sagemaker_session)