code: def trigger():
      return TemplateJobStartTrigger(
          project_id=PROJECT_ID,
          job_id=JOB_ID,
          location=LOCATION,
          gcp_conn_id=GCP_CONN_ID,
          poll_sleep=POLL_SLEEP,
          impersonation_chain=IMPERSONATION_CHAIN,
          cancel_timeout=CANCEL_TIMEOUT,
      )
  
file_path: airflow/tests/providers/google/cloud/triggers/test_dataflow.py
imports: from __future__ import annotations
  import asyncio
  import logging
  from unittest import mock
  import pytest
  from google.cloud.dataflow_v1beta3 import JobState
  from airflow.providers.google.cloud.triggers.dataflow import TemplateJobStartTrigger
  from airflow.triggers.base import TriggerEvent
label_desc: Use image node_id 1 for calling a global function with example usage: trigger() and returns: TemplateJobStartTrigger