code: def ensure_disk_not_overutilize(
      func: Callable[..., None]
  ) -> Callable[..., None]:
      raising_on_disk_issue = os.getenv(
          NEPTUNE_RAISE_ERROR_ON_DISK_USAGE_EXCEEDED, "True"
      ).lower() in ("true", "t", "1")
      max_disk_utilization = get_max_disk_utilization_from_env()
  
      error_handler = (
          RaisingErrorHandler
          if raising_on_disk_issue
          else NonRaisingErrorHandler
      )
  
      @wraps(func)
      def wrapper(*args: Any, **kwargs: Any) -> None:
          error_handler(
              max_disk_utilization, func, *args, **kwargs
          ).run()
  
      return wrapper
  
imports: import os
  from abc import ABC, abstractmethod
  from functools import wraps
  from typing import Any, Callable, Optional
  import psutil
  from psutil import Error
  from neptune.common.warnings import NeptuneWarning, warn_once
  from neptune.constants import NEPTUNE_DATA_DIRECTORY
  from neptune.envs import NEPTUNE_MAX_DISK_USAGE, NEPTUNE_RAISE_ERROR_ON_DISK_USAGE_EXCEEDED
  from neptune.exceptions import NeptuneMaxDiskUtilizationExceeded
label_desc: Use image node_id 4 for calling a global function with example usage: ensure_disk_not_overutilize(func) and returns: wrapper