Update app_parallel.py

app_parallel.py

@@ -306,7 +306,10 @@ def generate_chunks(audio_chunks, preprocessed_data, args, m3u8_path, audio_dura
                 processed_chunks[idx] = temp_file_path
                 for expected_start_time in sorted(processed_chunks.keys()):
                     if processed_chunks[expected_start_time] is not None:
-                        await asyncio.run(add_video(processed_chunks[expected_start_time], m3u8_path, audio_duration))
+                        loop = asyncio.new_event_loop()
+                        asyncio.set_event_loop(loop)
+                        loop.run_until_complete(add_video(processed_chunks[expected_start_time], m3u8_path, audio_duration)
+                        loop.close()
                         yield json.dumps({'start_time': expected_start_time, 'video_index': yielded_count}).encode('utf-8')
                         processed_chunks[expected_start_time] = None
                         yielded_count += 1