fix: task_chain group

This commit is contained in:
caoqianming 2023-08-02 14:38:22 +08:00
parent 5c3af36441
commit 25e49601a5
1 changed files with 1 additions and 1 deletions

View File

@ -177,7 +177,7 @@ def cal_mpointstats(is_now=1, year=None, month=None, day=None, hour=None):
mgroups_t_group.append(cal_enstat.s('hour_s', None, mgroup.id, year, month, day, hour, None, None, None, True, ['pcoal']))
# 最后计算enstat2
task_chain = chain(group(*mpoints_without_formula_group), group(*mpoints_other_group), group(*mgroups_group), group(*mgroups_t_group), group(cal_enstat2.s(year_s=year, month_s=month)))
task_chain = chain(group(mpoints_without_formula_group), group(mpoints_other_group), group(mgroups_group), group(mgroups_t_group), group([cal_enstat2.s(year_s=year, month_s=month)]))
task_chain.delay()
@shared_task(base=CustomTask)