mirror of
https://github.com/exo-explore/exo.git
synced 2025-12-23 22:27:50 -05:00
add retry count
This commit is contained in:
@@ -95,6 +95,7 @@ class Master:
|
||||
self._tg.cancel_scope.cancel()
|
||||
|
||||
async def _command_processor(self) -> None:
|
||||
retry_num = 0
|
||||
with self.command_receiver as commands:
|
||||
async for forwarder_command in commands:
|
||||
try:
|
||||
@@ -186,8 +187,11 @@ class Master:
|
||||
command.finished_command_id
|
||||
]
|
||||
case RequestEventLog():
|
||||
retry_num += 1
|
||||
# We should just be able to send everything, since other buffers will ignore old messages
|
||||
for i in range(command.since_idx, len(self._event_log)):
|
||||
ev = self._event_log[i]
|
||||
ev._retry = retry_num
|
||||
await self._send_event(
|
||||
IndexedEvent(idx=i, event=self._event_log[i])
|
||||
)
|
||||
|
||||
@@ -22,7 +22,8 @@ class EventId(Id):
|
||||
class BaseEvent(TaggedModel):
|
||||
event_id: EventId = Field(default_factory=EventId)
|
||||
# Internal, for debugging. Please don't rely on this field for anything!
|
||||
_master_time_stamp: None | datetime = None
|
||||
_master_time_stamp: datetime | None = None
|
||||
_retry: int | None = None
|
||||
|
||||
|
||||
class TestEvent(BaseEvent):
|
||||
|
||||
Reference in New Issue
Block a user