class_docstr: Factory class to generate executors for given step based on their types
class_docstr_tok: ["Factory","class","to","generate","executors","for","given","step","based","on","their","types"]
docstr: Return corresponding step executor for given step
docstr_tok: ["Return","corresponding","step","executor","for","given","step"]
code: def get(self, step: Step) -> _StepExecutor:
      """Return corresponding step executor for given step"""
  
      step_type = step.step_type
      step_executor = None
      if step_type == StepTypeEnum.TRAINING:
          step_executor = _TrainingStepExecutor(
              self.pipeline_executor, step
          )
      elif step_type == StepTypeEnum.PROCESSING:
          step_executor = _ProcessingStepExecutor(
              self.pipeline_executor, step
          )
      elif step_type == StepTypeEnum.TRANSFORM:
          step_executor = _TransformStepExecutor(
              self.pipeline_executor, step
          )
      elif step_type == StepTypeEnum.CREATE_MODEL:
          step_executor = _CreateModelStepExecutor(
              self.pipeline_executor, step
          )
      elif step_type == StepTypeEnum.FAIL:
          step_executor = _FailStepExecutor(
              self.pipeline_executor, step
          )
      elif step_type == StepTypeEnum.CONDITION:
          step_executor = _ConditionStepExecutor(
              self.pipeline_executor, step
          )
      else:
          self.pipeline_executor.execution.update_step_failure(
              step.name,
              f"Unsupported step type {step_type} to execute.",
          )
      return step_executor
  
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 2 for calling the _StepExecutorFactory obj's underlying member method code with example usage: obj.get(step) and returns: step_executor