mirror of
https://github.com/fawney19/Aether.git
synced 2026-01-02 15:52:26 +08:00
fix: 修复失败请求筛选兼容旧数据
失败请求筛选同时考虑新旧两种判断方式: - 新方式:status = "failed" - 旧方式:status_code >= 400 或 error_message 不为空
This commit is contained in:
@@ -171,7 +171,14 @@ const filteredRecords = computed(() => {
|
||||
} else if (filterStatus.value === 'completed') {
|
||||
records = records.filter(record => record.status === 'completed')
|
||||
} else if (filterStatus.value === 'failed') {
|
||||
records = records.filter(record => record.status === 'failed')
|
||||
// 失败请求需要同时考虑新旧两种判断方式:
|
||||
// 1. 新方式:status = "failed"
|
||||
// 2. 旧方式:status_code >= 400 或 error_message 不为空
|
||||
records = records.filter(record =>
|
||||
record.status === 'failed' ||
|
||||
(record.status_code && record.status_code >= 400) ||
|
||||
record.error_message
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -530,9 +530,18 @@ class AdminUsageRecordsAdapter(AdminApiAdapter):
|
||||
query = query.filter(
|
||||
(Usage.status_code >= 400) | (Usage.error_message.isnot(None))
|
||||
)
|
||||
elif self.status in ("pending", "streaming", "completed", "failed"):
|
||||
elif self.status in ("pending", "streaming", "completed"):
|
||||
# 新的状态筛选:直接按 status 字段过滤
|
||||
query = query.filter(Usage.status == self.status)
|
||||
elif self.status == "failed":
|
||||
# 失败请求需要同时考虑新旧两种判断方式:
|
||||
# 1. 新方式:status = "failed"
|
||||
# 2. 旧方式:status_code >= 400 或 error_message 不为空
|
||||
query = query.filter(
|
||||
(Usage.status == "failed") |
|
||||
(Usage.status_code >= 400) |
|
||||
(Usage.error_message.isnot(None))
|
||||
)
|
||||
elif self.status == "active":
|
||||
# 活跃请求:pending 或 streaming 状态
|
||||
query = query.filter(Usage.status.in_(["pending", "streaming"]))
|
||||
|
||||
Reference in New Issue
Block a user