code: def async_get_batch():
      def func(**kwargs):
          m = mock.MagicMock()
          m.configure_mock(**kwargs)
          f = Future()
          f.set_result(m)
          return f
  
      return func
  
imports: from __future__ import annotations
  import asyncio
  import logging
  from asyncio import Future
  from unittest import mock
  import pytest
  from google.cloud.dataproc_v1 import Batch, ClusterStatus
  from google.rpc.status_pb2 import Status
  from airflow.providers.google.cloud.triggers.dataproc import DataprocBatchTrigger, DataprocClusterTrigger, DataprocWorkflowTrigger
  from airflow.triggers.base import TriggerEvent
label_desc: Use image node_id 5 for calling a global function with example usage: async_get_batch() and returns: func, f