code: def trigger():
      return KubernetesPodTrigger(
          pod_name=POD_NAME,
          pod_namespace=NAMESPACE,
          base_container_name=BASE_CONTAINER_NAME,
          kubernetes_conn_id=CONN_ID,
          poll_interval=POLL_INTERVAL,
          cluster_context=CLUSTER_CONTEXT,
          config_file=CONFIG_FILE,
          in_cluster=IN_CLUSTER,
          get_logs=GET_LOGS,
          startup_timeout=STARTUP_TIMEOUT_SECS,
          trigger_start_time=TRIGGER_START_TIME,
          on_finish_action=ON_FINISH_ACTION,
      )
  
file_path: airflow/tests/providers/cncf/kubernetes/triggers/test_pod.py
imports: from __future__ import annotations
  import asyncio
  import datetime
  import logging
  from asyncio import CancelledError, Future
  from unittest import mock
  import pytest
  from kubernetes.client import models
  from airflow.providers.cncf.kubernetes.triggers.pod import ContainerState, KubernetesPodTrigger
  from airflow.providers.cncf.kubernetes.utils.pod_manager import PodPhase
  from airflow.triggers.base import TriggerEvent
label_desc: Use image node_id 1 for calling a global function with example usage: trigger() and returns: KubernetesPodTrigger