fix(scheduler): improve outbox job name

This commit is contained in:
jxxghp
2026-09-04 21:28:30 +08:00
parent 0d0bcf8a3b
commit 779db32ae7
2 changed files with 5 additions and 2 deletions
+2 -2
View File
@@ -217,7 +217,7 @@ class SchedulerCatalogOwner(_SchedulerOwnerBase):
self._register_database_backup_job(config)
outbox_job = JobSpec(
"outbox_dispatch",
"恢复待投递副作用",
"重试未完成的后台处理",
dispatch_pending_outbox,
"outbox",
recovery=JobRecoveryPolicy.DURABLE_QUEUE,
@@ -228,7 +228,7 @@ class SchedulerCatalogOwner(_SchedulerOwnerBase):
self.start,
"interval",
id="outbox_dispatch",
name="恢复待投递副作用",
name="重试未完成的后台处理",
seconds=30,
next_run_time=datetime.now(pytz.timezone(config.timezone)),
kwargs={"job_id": "outbox_dispatch"},
+3
View File
@@ -147,6 +147,9 @@ def test_clear_cache_is_manual_only(monkeypatch):
assert "clear_cache" not in scheduled_job_ids
assert "clear_cache" in scheduler._jobs
assert scheduler._jobs["clear_cache"]["manual"] is True
assert scheduler._jobs["outbox_dispatch"]["name"] == "重试未完成的后台处理"
outbox_job = next(job for job in background_scheduler.jobs if job["id"] == "outbox_dispatch")
assert outbox_job["name"] == "重试未完成的后台处理"
assert background_scheduler.started is True