code: def _execute_nodes(
      handle: metadata.Metadata,
      pipeline: pipeline_pb2.Pipeline,
      version: int,
  ):
      """Creates fake execution of nodes."""
      for node in pstate.get_all_nodes(pipeline):
          if node.node_info.id == "my_example_gen":
              test_utils.fake_example_gen_run_with_handle(
                  handle, node, 1, version
              )
          else:
              test_utils.fake_component_output_with_handle(
                  handle, node, active=False
              )
          pipeline_state = test_utils.get_or_create_pipeline_state(
              handle, pipeline
          )
          with pipeline_state:
              with pipeline_state.node_state_update_context(
                  task_lib.NodeUid.from_node(pipeline, node)
              ) as node_state:
                  node_state.update(
                      pstate.NodeState.COMPLETE,
                      status_lib.Status(
                          code=status_lib.Code.OK, message="all ok"
                      ),
                  )
  
imports: import os
  import tempfile
  from typing import Optional, Callable
  from absl import app
  from absl import flags
  from tfx.dsl.compiler import constants
  from tfx.orchestration import metadata
  from tfx.orchestration.experimental.core import pipeline_ops
  from tfx.orchestration.experimental.core import pipeline_state
  from tfx.orchestration.experimental.core import task
  from tfx.orchestration.experimental.core import test_utils
  from tfx.orchestration.experimental.core.testing import test_sync_pipeline
  from tfx.orchestration.portable import runtime_parameter_utils
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.utils import io_utils
  from tfx.utils import status
  from google.protobuf import message
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 3 for calling a global function with example usage: _execute_nodes(handle, pipeline, version) without return types