code: def mock_get_current_listener():
      with mock.patch(
          "mlflow._spark_autologging._get_current_listener",
          return_value=None,
      ) as get_listener_patch:
          yield get_listener_patch
  
file_path: mlflow/tests/spark/autologging/datasource/test_spark_datasource_autologging_unit.py
imports: from unittest import mock
  import pytest
  import mlflow
  import mlflow.spark
  from mlflow._spark_autologging import PythonSubscriber, _get_current_listener
  from mlflow.exceptions import MlflowException
  from tests.spark.autologging.utils import _get_or_create_spark_session
label_desc: Use image node_id 2 for calling a global function with example usage: mock_get_current_listener() without return types