code: def test_get_unprocessed_inputs_no_trigger(self):
      # Set the example_gen to transform node as NO_TRIGGER.
      input_trigger = self._transform.execution_options.async_trigger.input_triggers[
          "examples"
      ]
      input_trigger.no_trigger = True
  
      # ExampleGen generates the first output.
      otu.fake_example_gen_run(
          self._mlmd_connection, self._example_gen, 1, 1
      )
      resolved_info = task_gen_utils.generate_resolved_info(
          self._mlmd_connection_manager,
          node_proto_view.get_view(self._transform),
          self._pipeline,
      )
      unprocessed_inputs = task_gen_utils.get_unprocessed_inputs(
          self._mlmd_connection,
          resolved_info,
          self._transform,
      )
  
      # Should return one unprocessed input, and trigger transform once.
      self.assertLen(unprocessed_inputs, 1)
  
imports: import os
  import time
  from unittest import mock
  import uuid
  from absl.testing import parameterized
  import tensorflow
  from tfx import types
  from tfx import version
  from tfx.orchestration import data_types_utils
  from tfx.orchestration import node_proto_view
  from tfx.orchestration.experimental.core import constants
  from tfx.orchestration.experimental.core import pipeline_state
  from tfx.orchestration.experimental.core import task
  from tfx.orchestration.experimental.core import task_gen_utils
  from tfx.orchestration.experimental.core import test_utils
  from tfx.orchestration.experimental.core.testing import test_async_pipeline
  from tfx.orchestration.experimental.core.testing import test_dynamic_exec_properties_pipeline
  from tfx.orchestration import mlmd_connection_manager
  from tfx.orchestration.portable import outputs_utils
  from tfx.orchestration.portable.mlmd import execution_lib
  from tfx.proto.orchestration import execution_result_pb2
  from tfx.proto.orchestration import placeholder_pb2
  from tfx.types import artifact_utils
  from tfx.types import standard_artifacts
  from tfx.utils import status
  from tfx.utils import test_case_utils
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 18 for calling the TaskGenUtilsTest obj's underlying member method code with example usage: obj.test_get_unprocessed_inputs_no_trigger() without return types