mirror of
https://github.com/exo-explore/exo.git
synced 2025-12-23 22:27:50 -05:00
actually use it
This commit is contained in:
@@ -190,10 +190,10 @@ class Master:
|
||||
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
|
||||
event = self._event_log[i]
|
||||
event.retry = retry_num
|
||||
await self._send_event(
|
||||
IndexedEvent(idx=i, event=self._event_log[i])
|
||||
IndexedEvent(idx=i, event=event)
|
||||
)
|
||||
for event in generated_events:
|
||||
await self.event_sender.send(event)
|
||||
|
||||
@@ -23,7 +23,7 @@ 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: datetime | None = None
|
||||
_retry: int | None = None
|
||||
retry: int | None = None
|
||||
|
||||
|
||||
class TestEvent(BaseEvent):
|
||||
|
||||
Reference in New Issue
Block a user