Update app_parallel.py

app_parallel.py

@@ -311,7 +311,12 @@ def generate_chunks(audio_chunks, preprocessed_data, args, m3u8_path, audio_dura
                         add_video(processed_chunks[expected_start_time], m3u8_path, audio_duration)
                         end_time = time.time()
                         elapsed_time = end_time - start_time
-                        yield json.dumps({'start_time': expected_start_time, 'video_index': yielded_count, 'elapsed_time': elapsed_time}).encode('utf-8')
+                         event_data = json.dumps({
+                            'start_time': expected_start_time,
+                            'video_index': yielded_count,
+                            'elapsed_time': elapsed_time
+                        })
+                        yield f"data: {event_data}\n\n"
                         processed_chunks[expected_start_time] = None
                         yielded_count += 1
                     else: