# Create your tasks here from __future__ import absolute_import, unicode_literals from datetime import timedelta from apps.utils.tasks import CustomTask from celery import shared_task @shared_task(base=CustomTask) def generate_envdata(): pass @shared_task(base=CustomTask) def cal_envdata(): """ 计算监测达标率等值 """ pass