diff --git a/app/scheduler/catalog.py b/app/scheduler/catalog.py index fdb3fb55d..d68fa607b 100644 --- a/app/scheduler/catalog.py +++ b/app/scheduler/catalog.py @@ -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"}, diff --git a/tests/test_scheduler_cache_expiry.py b/tests/test_scheduler_cache_expiry.py index 675a7278e..f7841ecf2 100644 --- a/tests/test_scheduler_cache_expiry.py +++ b/tests/test_scheduler_cache_expiry.py @@ -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