We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c3472c4 commit 4ef6fecCopy full SHA for 4ef6fec
src/memos/mem_scheduler/task_schedule_modules/local_queue.py
@@ -245,15 +245,3 @@ def full(self) -> bool:
245
return any(
246
q.qsize() >= self.max_internal_message_queue_size for q in self.queue_streams.values()
247
)
248
-
249
- def ack_message(
250
- self,
251
- user_id: str,
252
- mem_cube_id: str,
253
- task_label: str,
254
- redis_message_id,
255
- message: ScheduleMessageItem | None,
256
- ) -> None:
257
- """
258
- Acknowledge a message (no-op for local queue as messages are popped immediately).
259
0 commit comments