log.py 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. import time
  2. from enum import Enum
  3. from typing import Dict, Tuple, Union
  4. from ray.util import PublicAPI
  5. from ray.util.annotations import DeveloperAPI
  6. @PublicAPI
  7. class Verbosity(Enum):
  8. V0_MINIMAL = 0
  9. V1_EXPERIMENT = 1
  10. V2_TRIAL_NORM = 2
  11. V3_TRIAL_DETAILS = 3
  12. def __int__(self):
  13. return self.value
  14. verbosity: Union[int, Verbosity] = Verbosity.V3_TRIAL_DETAILS
  15. @DeveloperAPI
  16. def set_verbosity(level: Union[int, Verbosity]):
  17. global verbosity
  18. if isinstance(level, int):
  19. verbosity = Verbosity(level)
  20. else:
  21. verbosity = level
  22. @DeveloperAPI
  23. def has_verbosity(level: Union[int, Verbosity]) -> bool:
  24. """Return True if passed level exceeds global verbosity level."""
  25. global verbosity
  26. log_level = int(level)
  27. verbosity_level = int(verbosity)
  28. return verbosity_level >= log_level
  29. @DeveloperAPI
  30. def disable_ipython():
  31. """Disable output of IPython HTML objects."""
  32. try:
  33. from IPython.core.interactiveshell import InteractiveShell
  34. InteractiveShell.clear_instance()
  35. except Exception:
  36. pass
  37. _log_cache_count: Dict[str, Tuple[str, float]] = {}
  38. def _dedup_logs(domain: str, value: str, repeat_after_s: int = 5) -> bool:
  39. cur_val, ts = _log_cache_count.get(domain, (None, None))
  40. if value == cur_val and time.monotonic() - repeat_after_s < ts:
  41. return False
  42. else:
  43. _log_cache_count[domain] = value, time.monotonic()
  44. return True