from celery import chain
chain(collect_detail.s(date), build_summary.s()).apply_async()

日报汇总表连续 5 天空数据,明细任务日志显示在汇总之后 8 分钟才完成,两个任务都是同一时刻被触发的。这类现象通常不是突然出现的,往前翻半天日志能看到苗头。

追下去是这么回事:两个任务各自被 beat 在同一分钟投递,谁先执行取决于 worker 空闲情况。代码里没有声明依赖,只靠时间上的先后,天然不可靠。

「任务依赖顺序」排查到最后往往是很小的一处差异,前面那些复杂猜测可以先放一放。同类问题如果隔一段时间又出现,多半是某个定时任务或重启流程把改动冲掉了。

处理上按这个顺序:用 chain 把明细和汇总串起来 前一个的返回值传给后一个;或者用 chord 等一组明细全部完成再触发汇总;汇总入口检查明细的完成标记 没齐就退出并重排;观察连续 3 天的日报 确认汇总时明细数量对得上。

确认没问题再收工,连续 3 天日报行数与明细条数一致 汇总任务的开始时间晚于最后一条明细。

作者 9823189