We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 891be0e commit fdb3404Copy full SHA for fdb3404
src/memos/mem_scheduler/task_schedule_modules/redis_queue.py
@@ -473,6 +473,8 @@ def get(
473
try:
474
# Convert Redis message back to SchedulerMessageItem
475
message = ScheduleMessageItem.from_dict(fields)
476
+ # Preserve stream key and redis message id for monitoring/ack
477
+ message.stream_key = _stream
478
message.redis_message_id = message_id
479
480
result_messages.append(message)
0 commit comments