fix: add missing enable_write_queue initialization in InferenceStore

This commit is contained in:
Ashwin Bharambe 2025-11-03 14:23:23 -08:00
parent 168c1209a0
commit b74752dd54

View file

@ -35,6 +35,7 @@ class InferenceStore:
self.reference = reference self.reference = reference
self.sql_store = None self.sql_store = None
self.policy = policy self.policy = policy
self.enable_write_queue = True
# Async write queue and worker control # Async write queue and worker control
self._queue: asyncio.Queue[tuple[OpenAIChatCompletion, list[OpenAIMessageParam]]] | None = None self._queue: asyncio.Queue[tuple[OpenAIChatCompletion, list[OpenAIMessageParam]]] | None = None