feat: ana_batch_thread 优化一下

This commit is contained in:
caoqianming 2025-09-18 10:44:23 +08:00
parent c2deb0ee45
commit e5a9f77f3d
1 changed files with 2 additions and 2 deletions

View File

@ -397,7 +397,7 @@ def mlog_submit(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
# 触发批次统计分析
xbatches = list(Mlogb.objects.filter(mlog=mlog).values_list('batch', flat=True))
ana_batch_thread(xbatches)
ana_batch_thread(xbatchs=xbatches, mgroup=mlog.mgroup)
# 触发单个统计
wprIds = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False, wpr__isnull=False).values_list('wpr__id', flat=True))
@ -619,7 +619,7 @@ def mlog_revert(mlog: Mlog, user: User, now: Union[datetime.datetime, None]):
# 触发批次统计分析
xbatches = list(Mlogb.objects.filter(mlog=mlog).values_list('batch', flat=True))
ana_batch_thread(xbatches)
ana_batch_thread(xbatches, mgroup=mlog.mgroup)
# 触发单个统计
wprIds = list(Mlogbw.objects.filter(mlogb__mlog=mlog, ftest__isnull=False, wpr__isnull=False).values_list('wpr__id', flat=True))