xref: /unit/test/python/lifespan/failed/asgi.py (revision 1628:93e2931202bb)
1*1628Szelenkov@nginx.comasync def application(scope, receive, send):
2*1628Szelenkov@nginx.com    if scope['type'] == 'lifespan':
3*1628Szelenkov@nginx.com        while True:
4*1628Szelenkov@nginx.com            message = await receive()
5*1628Szelenkov@nginx.com            if message['type'] == 'lifespan.startup':
6*1628Szelenkov@nginx.com                await send({"type": "lifespan.startup.failed"})
7*1628Szelenkov@nginx.com                raise Exception('Exception blah')
8*1628Szelenkov@nginx.com
9*1628Szelenkov@nginx.com            elif message['type'] == 'lifespan.shutdown':
10*1628Szelenkov@nginx.com                await send({'type': 'lifespan.shutdown.complete'})
11*1628Szelenkov@nginx.com                return
12