code: def async_get_data_scan_job():
      def func(**kwargs):
          m = mock.MagicMock()
          m.configure_mock(**kwargs)
          f = asyncio.Future()
          f.set_result(m)
          return f
  
      return func
  
file_path: airflow/tests/providers/google/cloud/triggers/test_dataplex.py
imports: from __future__ import annotations
  import asyncio
  import logging
  from unittest import mock
  import pytest
  from google.cloud.dataplex_v1.types import DataScanJob
  from airflow.providers.google.cloud.triggers.dataplex import DataplexDataQualityJobTrigger
  from airflow.triggers.base import TriggerEvent
label_desc: Use image node_id 2 for calling a global function with example usage: async_get_data_scan_job() and returns: func, f