feat: 优化ana_wpr3

This commit is contained in:
caoqianming 2025-07-04 20:14:58 +08:00
parent 14f3b215c4
commit 33f79b5cc5
1 changed files with 3 additions and 3 deletions

View File

@ -390,7 +390,7 @@ def mlog_submit(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
ana_batch_thread(xbatches)
# 触发单个统计
xnumbers = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False).values_list('number', flat=True))
xnumbers = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False, number__isnull=False).values_list('number', flat=True))
ana_wpr_thread(xnumbers, mlog.mgroup)
@ -607,8 +607,8 @@ def mlog_revert(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
ana_batch_thread(xbatches)
# 触发单个统计
xnumbers = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False).values_list('number', flat=True))
ana_wpr_thread(xnumbers)
xnumbers = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False, number__isnull=False).values_list('number', flat=True))
ana_wpr_thread(xnumbers, mlog.mgroup)
def cal_mtask_progress_from_mlog(mlog:Mlog):
"""