Update app_celery.py

app_celery.py

@@ -548,8 +548,10 @@ def stream_video_chunks():
                 video_chunk_path = task.get()  # Wait for each task to complete
                 video_chunk_paths.append(video_chunk_path)
                 print("video_chunk_paths",video_chunk_paths)
-                yield f'data: {video_chunk_path}\n\n'  # Send the chunk path to the frontend
+                yield f'data: {video_chunk_path}\n\n'
                 print(f"Chunk {index} generated and sent: {video_chunk_path}")
+                os.remove(video_chunk_path)
+                print(f"Deleted video chunk: {video_chunk_path}")
             except Exception as e:
                 print(f"Error while fetching task result: {str(e)}")
                 yield f'data: error\n\n'