fix(scheduler): propagate status_tracker to SchedulerRedisQueue in ScheduleTaskQueue

glin1993@outlook.com · glin1993@outlook.com · commit f5b009ec5560 · 2025-12-09T11:20:29.000+08:00
diff --git a/src/memos/mem_scheduler/task_schedule_modules/task_queue.py b/src/memos/mem_scheduler/task_schedule_modules/task_queue.py
@@ -42,6 +42,7 @@ def __init__(
                 consumer_group="scheduler_group",
                 consumer_name="scheduler_consumer",
                 orchestrator=self.orchestrator,
+                status_tracker=self.status_tracker,  # Propagate status_tracker
             )
         else:
             self.memos_message_queue = SchedulerLocalQueue(maxsize=self.maxsize)

Original file line number	Diff line number	Diff line change
`@@ -42,6 +42,7 @@ def __init__(`
`42`	`42`	`consumer_group="scheduler_group",`
`43`	`43`	`consumer_name="scheduler_consumer",`
`44`	`44`	`orchestrator=self.orchestrator,`
	`45`	`+ status_tracker=self.status_tracker, # Propagate status_tracker`
`45`	`46`	`)`
`46`	`47`	`else:`
`47`	`48`	`self.memos_message_queue = SchedulerLocalQueue(maxsize=self.maxsize)`