Skip to content

Commit 1682e6e

Browse files
fix: preserve stream key on redis dequeue
1 parent cd524c2 commit 1682e6e

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/memos/mem_scheduler/task_schedule_modules/redis_queue.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -473,6 +473,8 @@ def get(
473473
try:
474474
# Convert Redis message back to SchedulerMessageItem
475475
message = ScheduleMessageItem.from_dict(fields)
476+
# Preserve stream key and redis message id for monitoring/ack
477+
message.stream_key = _stream
476478
message.redis_message_id = message_id
477479

478480
result_messages.append(message)

0 commit comments

Comments
 (0)