mirror of
https://github.com/jxxghp/MoviePilot.git
synced 2026-08-29 03:56:43 +08:00
test(governance): satisfy reliability gates
This commit is contained in:
@@ -9,8 +9,8 @@ from typing import Any, Protocol
|
||||
|
||||
from app.application.outbox import (
|
||||
OUTBOX_LEASE_SECONDS,
|
||||
OutboxIntent,
|
||||
SUBSCRIBE_COMPLETED_TOPIC,
|
||||
OutboxIntent,
|
||||
SyncOutboxTransaction,
|
||||
SyncUnitOfWork,
|
||||
)
|
||||
|
||||
@@ -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 后台机制映射
|
||||
|
||||
@@ -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": (
|
||||
|
||||
Reference in New Issue
Block a user