code: def test_pipeline(sagemaker_session):
      param = ParameterInteger(name="MyInt", default_value=2)
      cond = ConditionEquals(left=param, right=1)
      custom_step1 = CustomStep("IfStep")
      custom_step2 = CustomStep("ElseStep")
      step_cond = ConditionStep(
          name="CondStep",
          conditions=[cond],
          if_steps=[custom_step1],
          else_steps=[custom_step2],
      )
      pipeline = Pipeline(
          name="MyPipeline",
          steps=[step_cond],
          sagemaker_session=sagemaker_session,
          parameters=[param],
      )
      adjacency_list = PipelineGraph.from_pipeline(
          pipeline
      ).adjacency_list
      assert ordered(adjacency_list) == ordered(
          {
              "CondStep": ["IfStep", "ElseStep"],
              "IfStep": [],
              "ElseStep": [],
          }
      )
  
imports: from __future__ import absolute_import
  import json
  from sagemaker.remote_function.job import _JobSettings
  from sagemaker.workflow.conditions import ConditionEquals, ConditionGreaterThan, ConditionGreaterThanOrEqualTo, ConditionIn, ConditionLessThan, ConditionLessThanOrEqualTo, ConditionNot, ConditionOr
  from sagemaker.workflow.execution_variables import ExecutionVariables
  from sagemaker.workflow.function_step import step
  from sagemaker.workflow.parameters import ParameterInteger, ParameterString
  from sagemaker.workflow.condition_step import ConditionStep
  from sagemaker.workflow.pipeline import Pipeline, PipelineGraph
  from tests.unit.sagemaker.workflow.helpers import CustomStep, ordered
label_desc: Use image node_id 4 for calling a global function with example usage: test_pipeline(sagemaker_session) without return types