diff --git a/app/application/subscription/complete.py b/app/application/subscription/complete.py index 19e174fff..563b96457 100644 --- a/app/application/subscription/complete.py +++ b/app/application/subscription/complete.py @@ -9,8 +9,8 @@ from typing import Any, Protocol from app.application.outbox import ( OUTBOX_LEASE_SECONDS, - OutboxIntent, SUBSCRIBE_COMPLETED_TOPIC, + OutboxIntent, SyncOutboxTransaction, SyncUnitOfWork, ) diff --git a/docs/adr/0007-background-action-reliability.md b/docs/adr/0007-background-action-reliability.md index e234557b9..9c025b810 100644 --- a/docs/adr/0007-background-action-reliability.md +++ b/docs/adr/0007-background-action-reliability.md @@ -54,7 +54,8 @@ Event Contract Registry 是 53 个事件的逐项机器清单。下表按相同 通知和服务端上报必须由同事务 durable intent 驱动。ARCH-251 首选 `SubscribeAdded` pilot。 - `DownloadAdded`:下载器确认接收后,下载历史与事件 intent 已在返回前原子提交;通知和模块后处理只在 commit 后启动,事件由 Outbox 恢复投递。 -- `TransferComplete`、`TransferFailed` 以及对应的字幕、音频完成/失败事件:整理步骤本身属于 E3, +- `TransferComplete`、`TransferFailed`、`SubtitleTransferComplete`、`SubtitleTransferFailed`、 + `AudioTransferComplete`、`AudioTransferFailed`:整理步骤本身属于 E3, 但历史行提交后向事件消费者发布结果属于 E2,使用同一 JSON 快照与恢复 handler。 ## 非 Event 后台机制映射 diff --git a/tests/test_cleanup_index_migration.py b/tests/test_cleanup_index_migration.py index b95892653..bff07d3cd 100644 --- a/tests/test_cleanup_index_migration.py +++ b/tests/test_cleanup_index_migration.py @@ -6,7 +6,6 @@ import sqlalchemy as sa from alembic.migration import MigrationContext from alembic.operations import Operations - MIGRATION_MODULE = "database.versions.a6c8e2f4b1d3_3_0_11" INDEXES = { "subscribehistory": (