code: def _test_task(node_id, pipeline_id):
      node_uid = task_lib.NodeUid(
          pipeline_uid=task_lib.PipelineUid(pipeline_id=pipeline_id),
          node_id=node_id,
      )
      return test_utils.create_exec_node_task(node_uid)
  
file_path: tfx/tfx/orchestration/experimental/core/task_queue_test.py
imports: import tensorflow
  from tfx.orchestration.experimental.core import task
  from tfx.orchestration.experimental.core import task_queue
  from tfx.orchestration.experimental.core import test_utils
  from tfx.utils import test_case_utils
label_desc: Use image node_id 1 for calling a global function with example usage: _test_task(node_id, pipeline_id) and returns: test_utils