Update server.py

server.py

@@ -1,7 +1,7 @@
 import asyncio
 from concurrent.futures import ThreadPoolExecutor
 
-from fastapi import FastAPI, Response, Request
+from fastapi import FastAPI, Response, Request, BackgroundTasks
 from starlette.middleware.cors import CORSMiddleware
 # import json
 # from load_data import get_design_data, get_design_resolutions_for_shop
@@ -50,12 +50,13 @@ async def root():
 
 
 @app.post("/lal_for_shop")
-async def submit_async_task(request: Request, response: Response, shop: Shop):
-    loop = asyncio.new_event_loop()
+async def submit_async_task(request: Request, response: Response,background_tasks: BackgroundTasks, shop: Shop):
+    # loop = asyncio.new_event_loop()
     authorization_token = request.headers.get("Authorization", None)
     check_token = check_auth(authorization_token)
     if check_token:
-        task = asyncio.create_task(create_feature_files(shop))
+        # task = asyncio.create_task(create_feature_files(shop))
+        background_tasks.add_task(create_feature_files, shop)
         return {"message": f"shop calculation for shop {shop.id} submitted"}
     else:
         print(authorization_token)