from __future__ import absolute_import from celery.task import Task import time class monitoring(Task): def run(self): time.sleep(5) print("monitoring")