|
|
@@ -164,6 +164,8 @@ async def wait_finish(video_data:dict):
|
|
|
await process.wait()
|
|
|
|
|
|
task = celery_app.send_task("app.worker.make_video", kwargs=video_data)
|
|
|
+
|
|
|
+ video = supabase.table(VIDEO_TABLE).update({"uuid":task.id}).eq('id', video_data['id']).execute()
|
|
|
while True:
|
|
|
await asyncio.sleep(1)
|
|
|
if task.state != "PENDING":
|
|
|
@@ -208,7 +210,7 @@ async def wait_finish(video_data:dict):
|
|
|
print(f"Discord response: {response.status_code}")
|
|
|
|
|
|
else:
|
|
|
- video = supabase.table(VIDEO_TABLE).update({"progress_state":"FAILUR", "error_message":str(task.result)}).eq('id', video_data['id']).execute()
|
|
|
+ video = supabase.table(VIDEO_TABLE).update({"progress_state":"FAILURE", "error_message":str(task.result)}).eq('id', video_data['id']).execute()
|
|
|
msg_data = f"{video_data['stored_filename']}:FAILURE:{task.result}"
|
|
|
message = f'edm-choozmo-com\n \
|
|
|
Video\n \
|
