user.billing_job: fix unwanted await due to spawn() being non-coro

This commit is contained in:
Luna Mendes 2018-11-17 18:01:53 -03:00
parent 041791b733
commit 1cef25ffc4
2 changed files with 2 additions and 1 deletions

View File

@ -26,7 +26,7 @@ THRESHOLDS = {
async def _resched(app): async def _resched(app):
log.debug('waiting 2 minutes for job.') log.debug('waiting 2 minutes for job.')
await sleep(120) await sleep(120)
await app.sched.spawn(payment_job(app)) app.sched.spawn(payment_job(app))
async def _process_user_payments(app, user_id: int): async def _process_user_payments(app, user_id: int):

View File

@ -20,6 +20,7 @@ class JobManager:
task = self.loop.create_task( task = self.loop.create_task(
self._wrapper(coro) self._wrapper(coro)
) )
self.jobs.append(task) self.jobs.append(task)
def close(self): def close(self):