code: def apply_function_true(message):
      return True
  
file_path: airflow/tests/providers/apache/kafka/triggers/test_await_message.py
imports: from __future__ import annotations
  import asyncio
  import json
  import pytest
  from airflow.models import Connection
  from airflow.providers.apache.kafka.hooks.consume import KafkaConsumerHook
  from airflow.providers.apache.kafka.triggers.await_message import AwaitMessageTrigger
  from airflow.utils import db
label_desc: Use image node_id 2 for calling a global function with example usage: apply_function_true(message) and returns: True