forget

backend/app/app/api/api_v1/endpoints/edm_saas_api.py

@@ -233,7 +233,7 @@ async def wait_finish(video_data:dict):
         webhook = DiscordWebhook(url=Discord_URL, content=message)
         response = webhook.execute()
         print(f"Discord response: {response.status_code}")
-
+    task.forget()
     await publish(msg_data)
 
 async def publish(data):

backend/app/app/api/api_v1/endpoints/videos.py

@@ -222,6 +222,7 @@ async def wait_finish(video_data:dict):
             response = webhook.execute()
             print(f"Discord response: {response.status_code}")
     elif task.state == "FAILURE":
+
         db = SessionLocal()
         video = db.query(models.Video).get(video_data['id'])
         video.progress_state = "FAILURE" 
@@ -239,7 +240,7 @@ async def wait_finish(video_data:dict):
         webhook = DiscordWebhook(url=Discord_URL, content=message)
         response = webhook.execute()
         print(f"Discord response: {response.status_code}")
-
+    task.forget()
     await publish(msg_data)
 
 async def publish(data):