event.py 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273
  1. from dataclasses import dataclass
  2. from datetime import datetime
  3. from enum import Enum
  4. from openhands.core.metrics import Metrics
  5. class EventSource(str, Enum):
  6. AGENT = 'agent'
  7. USER = 'user'
  8. @dataclass
  9. class Event:
  10. @property
  11. def message(self) -> str | None:
  12. if hasattr(self, '_message'):
  13. return self._message # type: ignore[attr-defined]
  14. return ''
  15. @property
  16. def id(self) -> int:
  17. if hasattr(self, '_id'):
  18. return self._id # type: ignore[attr-defined]
  19. return -1
  20. @property
  21. def timestamp(self):
  22. if hasattr(self, '_timestamp') and isinstance(self._timestamp, str):
  23. return self._timestamp
  24. @timestamp.setter
  25. def timestamp(self, value: datetime) -> None:
  26. if isinstance(value, datetime):
  27. self._timestamp = value.isoformat()
  28. @property
  29. def source(self) -> EventSource | None:
  30. if hasattr(self, '_source'):
  31. return self._source # type: ignore[attr-defined]
  32. return None
  33. @property
  34. def cause(self) -> int | None:
  35. if hasattr(self, '_cause'):
  36. return self._cause # type: ignore[attr-defined]
  37. return None
  38. @property
  39. def timeout(self) -> int | None:
  40. if hasattr(self, '_timeout'):
  41. return self._timeout # type: ignore[attr-defined]
  42. return None
  43. @timeout.setter
  44. def timeout(self, value: int | None) -> None:
  45. self._timeout = value
  46. # Check if .blocking is an attribute of the event
  47. if hasattr(self, 'blocking'):
  48. # .blocking needs to be set to True if .timeout is set
  49. self.blocking = True
  50. # optional metadata, LLM call cost of the edit
  51. @property
  52. def llm_metrics(self) -> Metrics | None:
  53. if hasattr(self, '_llm_metrics'):
  54. return self._llm_metrics # type: ignore[attr-defined]
  55. return None
  56. @llm_metrics.setter
  57. def llm_metrics(self, value: Metrics) -> None:
  58. self._llm_metrics = value