Skip to content

Commit

Permalink
Merge branch 'main' into bp-group-name-prefix
Browse files Browse the repository at this point in the history
  • Loading branch information
ahopkins committed Jul 5, 2023
2 parents 0c736d9 + f2cc83c commit 4f2a5e0
Show file tree
Hide file tree
Showing 8 changed files with 45 additions and 40 deletions.
4 changes: 2 additions & 2 deletions examples/amending_request_object.py
Expand Up @@ -25,5 +25,5 @@ def key_exist_handler(request):

return text("num does not exist in request")


app.run(host="0.0.0.0", port=8000, debug=True)
if __name__ == "__main__":
app.run(host="0.0.0.0", port=8000, debug=True)
3 changes: 2 additions & 1 deletion examples/blueprint_middlware_execution_order.py
Expand Up @@ -50,4 +50,5 @@ def pop_handler(request):

app.blueprint(bp, url_prefix="/bp")

app.run(host="0.0.0.0", port=8000, debug=True, auto_reload=False)
if __name__ == "__main__":
app.run(host="0.0.0.0", port=8000, debug=True, auto_reload=False)
3 changes: 2 additions & 1 deletion examples/blueprints.py
Expand Up @@ -37,4 +37,5 @@ async def foo3(request, ws):
app.blueprint(blueprint2)
app.blueprint(blueprint3)

app.run(host="0.0.0.0", port=9999, debug=True)
if __name__ == "__main__":
app.run(host="0.0.0.0", port=9999, debug=True)
4 changes: 2 additions & 2 deletions examples/http_redirect.py
Expand Up @@ -69,5 +69,5 @@ async def runner(app: Sanic, app_server: AsyncioServer):
app.is_running = False
app.is_stopping = True


https.run(port=HTTPS_PORT, debug=True)
if __name__ == "__main__":
https.run(port=HTTPS_PORT, debug=True)
3 changes: 2 additions & 1 deletion examples/limit_concurrency.py
Expand Up @@ -39,4 +39,5 @@ async def test(request):
return json(response)


app.run(host="0.0.0.0", port=8000, workers=2)
if __name__ == "__main__":
app.run(host="0.0.0.0", port=8000, workers=2)
3 changes: 2 additions & 1 deletion examples/override_logging.py
Expand Up @@ -20,4 +20,5 @@ def test(request):
return text("hey")


app.run(host="0.0.0.0", port=8000)
if __name__ == "__main__":
app.run(host="0.0.0.0", port=8000)
3 changes: 2 additions & 1 deletion examples/request_timeout.py
Expand Up @@ -20,4 +20,5 @@ def timeout(request, exception):
return response.text("RequestTimeout from error_handler.", 408)


app.run(host="0.0.0.0", port=8000)
if __name__ == "__main__":
app.run(host="0.0.0.0", port=8000)
62 changes: 31 additions & 31 deletions examples/run_async_advanced.py
Expand Up @@ -35,34 +35,34 @@ async def after_server_stop(app, loop):
async def test(request):
return response.json({"answer": "42"})


asyncio.set_event_loop(uvloop.new_event_loop())
serv_coro = app.create_server(
host="0.0.0.0", port=8000, return_asyncio_server=True
)
loop = asyncio.get_event_loop()
serv_task = asyncio.ensure_future(serv_coro, loop=loop)
signal(SIGINT, lambda s, f: loop.stop())
server: AsyncioServer = loop.run_until_complete(serv_task)
loop.run_until_complete(server.startup())

# When using app.run(), this actually triggers before the serv_coro.
# But, in this example, we are using the convenience method, even if it is
# out of order.
loop.run_until_complete(server.before_start())
loop.run_until_complete(server.after_start())
try:
loop.run_forever()
except KeyboardInterrupt:
loop.stop()
finally:
loop.run_until_complete(server.before_stop())

# Wait for server to close
close_task = server.close()
loop.run_until_complete(close_task)

# Complete all tasks on the loop
for connection in server.connections:
connection.close_if_idle()
loop.run_until_complete(server.after_stop())
if __name__ == "__main__":
asyncio.set_event_loop(uvloop.new_event_loop())
serv_coro = app.create_server(
host="0.0.0.0", port=8000, return_asyncio_server=True
)
loop = asyncio.get_event_loop()
serv_task = asyncio.ensure_future(serv_coro, loop=loop)
signal(SIGINT, lambda s, f: loop.stop())
server: AsyncioServer = loop.run_until_complete(serv_task)
loop.run_until_complete(server.startup())

# When using app.run(), this actually triggers before the serv_coro.
# But, in this example, we are using the convenience method, even if it is
# out of order.
loop.run_until_complete(server.before_start())
loop.run_until_complete(server.after_start())
try:
loop.run_forever()
except KeyboardInterrupt:
loop.stop()
finally:
loop.run_until_complete(server.before_stop())

# Wait for server to close
close_task = server.close()
loop.run_until_complete(close_task)

# Complete all tasks on the loop
for connection in server.connections:
connection.close_if_idle()
loop.run_until_complete(server.after_stop())

0 comments on commit 4f2a5e0

Please sign in to comment.