Skip to content

Commit c3da592

Browse files
cephalonautoz-agent
andcommitted
Rename enqueue_polled_events to enqueue_event_batch
Internal sink method on OrchestrationEventService still carried the "polled" name from the old polling path. The streamer is its sole caller; renaming aligns it with the streamer's handle_event_batch terminology. No behavior change. Co-Authored-By: Oz <oz-agent@warp.dev>
1 parent 4e7ad1f commit c3da592

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

app/src/ai/blocklist/orchestration_event_streamer.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -352,7 +352,7 @@ impl OrchestrationEventStreamer {
352352

353353
let pending = build_pending_events(messages, lifecycle_events);
354354
OrchestrationEventService::handle(ctx).update(ctx, |svc, ctx| {
355-
svc.enqueue_polled_events(conversation_id, pending, ctx);
355+
svc.enqueue_event_batch(conversation_id, pending, ctx);
356356
});
357357
}
358358

app/src/ai/blocklist/orchestration_events.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -829,10 +829,10 @@ impl OrchestrationEventService {
829829
}
830830
}
831831

832-
/// Accepts pre-built events from the v2 poller and enqueues them
832+
/// Accepts pre-built events from the v2 streamer and enqueues them
833833
/// for drain by the controller via the normal v1 path.
834834
/// Lifecycle events go through coalescing and cap enforcement.
835-
pub fn enqueue_polled_events(
835+
pub fn enqueue_event_batch(
836836
&mut self,
837837
conversation_id: AIConversationId,
838838
events: Vec<PendingEvent>,

0 commit comments

Comments
 (0)