def handle(self, *args, **options):
schedule.every(1).hours.do(tasks.kill_obsolete_timers)
schedule.every(5).seconds.do(tasks.send_reminders)
self.stdout.write(self.style.SUCCESS('Starting job runner...'))
while True:
time.sleep(1)
try:
schedule.run_pending()
except:
traceback.print_exc()
评论列表
文章目录