code: def _check_last_log_masked_variable(
      session, dag_id, event, execution_date
  ):
      logs = (
          session.query(
              Log.dag_id,
              Log.task_id,
              Log.event,
              Log.execution_date,
              Log.owner,
              Log.extra,
          )
          .filter(
              Log.dag_id == dag_id,
              Log.event == event,
              Log.execution_date == execution_date,
          )
          .order_by(Log.dttm.desc())
          .limit(5)
          .all()
      )
      assert len(logs) >= 1
      extra_dict = ast.literal_eval(logs[0].extra)
      assert extra_dict == [("key", "x_secret"), ("val", "***")]
  
file_path: airflow/tests/test_utils/www.py
imports: from __future__ import annotations
  import ast
  from unittest import mock
  from airflow.models import Log
label_desc: Use image node_id 8 for calling a global function with example usage: _check_last_log_masked_variable(session, dag_id, event, execution_date) without return types