from apscheduler.schedulers.asyncio import AsyncIOScheduler

scheduler = AsyncIOScheduler({
    'apscheduler.jobstores.mongo': {
        'type': 'mongodb'
    }
})

scheduler.start()

time_job = scheduler.add_job(tasks.expiry, 'cron', hour='0', minute='0,1', args=[app], id='time')

发表评论