code: def trigger():
      return CloudRunJobFinishedTrigger(
          operation_name=OPERATION_NAME,
          job_name=JOB_NAME,
          project_id=PROJECT_ID,
          location=LOCATION,
          gcp_conn_id=GCP_CONNECTION_ID,
          polling_period_seconds=POLL_SLEEP,
          timeout=TIMEOUT,
          impersonation_chain=IMPERSONATION_CHAIN,
      )
  
file_path: airflow/tests/providers/google/cloud/triggers/test_cloud_run.py
imports: from __future__ import annotations
  from unittest import mock
  import pytest
  from google.protobuf.any_pb2 import Any
  from google.rpc.status_pb2 import Status
  from airflow.providers.google.cloud.triggers.cloud_run import CloudRunJobFinishedTrigger, RunJobStatus
  from airflow.triggers.base import TriggerEvent
label_desc: Use image node_id 1 for calling a global function with example usage: trigger() and returns: CloudRunJobFinishedTrigger