Rename enqueue_polled_events to enqueue_event_batch

cephalonaut · oz-agent · cephalonaut · commit 604a10ffbc20 · 2026-04-28T15:14:06.000-04:00
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 &lt;oz-agent@warp.dev&gt;
diff --git a/app/src/ai/blocklist/orchestration_events.rs b/app/src/ai/blocklist/orchestration_events.rs
@@ -865,10 +865,10 @@ impl OrchestrationEventService {
         }
     }
 
-    /// Accepts pre-built events from the v2 poller and enqueues them
+    /// Accepts pre-built events from the v2 streamer and enqueues them
     /// for drain by the controller via the normal v1 path.
     /// Lifecycle events go through coalescing and cap enforcement.
-    pub fn enqueue_polled_events(
+    pub fn enqueue_event_batch(
         &mut self,
         conversation_id: AIConversationId,
         events: Vec<PendingEvent>,

Original file line number	Diff line number	Diff line change
`@@ -865,10 +865,10 @@ impl OrchestrationEventService {`
`865`	`865`	`}`
`866`	`866`	`}`
`867`	`867`
`868`		`- /// Accepts pre-built events from the v2 poller and enqueues them`
	`868`	`+ /// Accepts pre-built events from the v2 streamer and enqueues them`
`869`	`869`	`/// for drain by the controller via the normal v1 path.`
`870`	`870`	`/// Lifecycle events go through coalescing and cap enforcement.`
`871`		`- pub fn enqueue_polled_events(`
	`871`	`+ pub fn enqueue_event_batch(`
`872`	`872`	`&mut self,`
`873`	`873`	`conversation_id: AIConversationId,`
`874`	`874`	`events: Vec<PendingEvent>,`