code: def _test() -> None:
      import doctest
      import sys
      from pyspark.context import SparkContext
      from pyspark.sql import SparkSession
      import pyspark.sql.observation
  
      globs = pyspark.sql.observation.__dict__.copy()
      sc = SparkContext("local[4]", "PythonTest")
      globs["spark"] = SparkSession(sc)
  
      (failure_count, test_count) = doctest.testmod(
          pyspark.sql.observation, globs=globs
      )
      sc.stop()
      if failure_count:
          sys.exit(-1)
  
file_path: spark/python/pyspark/sql/observation.py
imports: import os
  from typing import Any, Dict, Optional
  from py4j.java_gateway import JavaObject, JVMView
  from pyspark.errors import PySparkTypeError, PySparkValueError, PySparkAssertionError
  from pyspark.sql import column
  from pyspark.sql.column import Column
  from pyspark.sql.dataframe import DataFrame
  from pyspark.sql.utils import is_remote
label_desc: Use image node_id 1 for calling a global function with example usage: _test() without return types