mirror of
https://github.com/exo-explore/exo.git
synced 2025-10-23 02:57:14 +03:00
super secret fix
This commit is contained in:
@@ -306,6 +306,8 @@ class API:
|
||||
async def _apply_state(self):
|
||||
with self.global_event_receiver as events:
|
||||
async for event in events:
|
||||
if isinstance(event, ChunkGenerated):
|
||||
logger.info(f"API received ChunkGenerated: {str(event)[:100]}")
|
||||
self.event_buffer.ingest(event.origin_idx, event.tagged_event.c)
|
||||
for idx, event in self.event_buffer.drain_indexed():
|
||||
self.state = apply(self.state, IndexedEvent(event=event, idx=idx))
|
||||
|
||||
@@ -652,9 +652,6 @@ class Worker:
|
||||
)
|
||||
await self.local_event_sender.send(fe)
|
||||
self.out_for_delivery[event.event_id] = fe
|
||||
logger.info(
|
||||
f"Worker published event {self.local_event_index}: {str(event)[:100]}...{str(event)[-100:]}"
|
||||
)
|
||||
self.local_event_index += 1
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user