try to inject the app in add_task method

This commit is contained in:
Raphael Deem 2017-12-21 17:12:31 -08:00
parent 008cbe5ce7
commit a1ffc6d55b
2 changed files with 25 additions and 2 deletions

View File

@ -88,14 +88,20 @@ class Sanic:
"""
try:
if callable(task):
self.loop.create_task(task())
try:
self.loop.create_task(task(self))
except TypeError:
self.loop.create_task(task())
else:
self.loop.create_task(task)
except SanicException:
@self.listener('before_server_start')
def run(app, loop):
if callable(task):
loop.create_task(task())
try:
loop.create_task(task(self))
except TypeError:
loop.create_task(task())
else:
loop.create_task(task)

View File

@ -2,6 +2,7 @@ from sanic import Sanic
from sanic.response import text
from threading import Event
import asyncio
from queue import Queue
def test_create_task():
@ -28,3 +29,19 @@ def test_create_task():
request, response = app.test_client.get('/late')
assert response.body == b'True'
def test_create_task_with_app_arg():
app = Sanic('test_add_task')
q = Queue()
@app.route('/')
def not_set(request):
return "hello"
async def coro(app):
q.put(app.name)
app.add_task(coro)
request, response = app.test_client.get('/')
assert q.get() == 'test_add_task'