Fixing task cancellation in main
This commit is contained in:
parent
003284ccba
commit
51e446710b
1 changed files with 10 additions and 3 deletions
13
src/main.py
13
src/main.py
|
@ -7,11 +7,18 @@ from endpoints.bettwaage import router as bettwaage_router
|
|||
from endpoints.handlers.fritz import track_network_devices
|
||||
|
||||
app = FastAPI()
|
||||
asyncio.create_task(track_network_devices())
|
||||
asyncio.create_task(log_bed_weights())
|
||||
|
||||
loop = asyncio.new_event_loop()
|
||||
loop.create_task(track_network_devices())
|
||||
loop.create_task(log_bed_weights())
|
||||
|
||||
app.include_router(hue_router, prefix="/hue", tags=["hue"])
|
||||
app.include_router(bettwaage_router, prefix="/bettwaage", tags=["bett"])
|
||||
|
||||
if __name__ == "__main__":
|
||||
asyncio.run(lambda: uvicorn.run("main:app", host="0.0.0.0", port=8000, reload=True))
|
||||
uvicorn.run("main:app", host="0.0.0.0", port=8000, reload=True)
|
||||
# Ende tasks
|
||||
tasks = asyncio.all_tasks(loop)
|
||||
[t.cancel() for t in tasks]
|
||||
asyncio.gather(*tasks)
|
||||
loop.stop()
|
||||
|
|
Loading…
Reference in a new issue