code: def validate_trigger_event(event: dict):
      """
      Validate correctness of the event received from DatabricksExecutionTrigger.
  
      See: :class:`~airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger`.
      """
      keys_to_check = ["run_id", "run_page_url", "run_state"]
      for key in keys_to_check:
          if key not in event:
              raise AirflowException(
                  f"Could not find `{key}` in the event: {event}"
              )
  
      try:
          RunState.from_json(event["run_state"])
      except Exception:
          raise AirflowException(
              f'Run state returned by the Trigger is incorrect: {event["run_state"]}'
          )
  
imports: from __future__ import annotations
  from airflow.exceptions import AirflowException
  from airflow.providers.databricks.hooks.databricks import RunState
label_desc: Use image node_id 2 for calling a global function with example usage: validate_trigger_event(event) without return types