code: def _return_true(message):
      return True
  
file_path: airflow/tests/providers/apache/kafka/sensors/test_kafka.py
imports: from __future__ import annotations
  import json
  import logging
  import pytest
  from airflow.exceptions import TaskDeferred
  from airflow.models import Connection
  from airflow.providers.apache.kafka.sensors.kafka import AwaitMessageSensor, AwaitMessageTriggerFunctionSensor
  from airflow.utils import db
label_desc: Use image node_id 1 for calling a global function with example usage: _return_true(message) and returns: True