minor bugs

gradio-app · Aug 1, 2024 · 5849f93 · 5849f93
1 parent bec44f8
commit 5849f93
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 16 deletions.
diff --git a/gradio/queueing.py b/gradio/queueing.py
@@ -654,22 +654,23 @@ async def process_events(
                         return
                     try:
                         start = time.monotonic()
-                        awake_events, closed_events = await Queue.wait_for_batch(
-                            awake_events,
-                            [cast(float, fn.time_limit) - first_iteration]
-                            * len(awake_events),
-                        )
-                        for closed_event in closed_events:
-                            self.log_message(
-                                closed_event._id,
-                                "Time limit reached! Please join the queue again.",
-                                "info",
-                                duration=10,
-                            )
-                            self.send_message(
-                                closed_event,
-                                ProcessCompletedMessage(output=response, success=True),
+                        if awake_events[0].streaming:
+                            awake_events, closed_events = await Queue.wait_for_batch(
+                                awake_events,
+                                [cast(float, fn.time_limit) - first_iteration]
+                                * len(awake_events),
                             )
+                            for closed_event in closed_events:
+                                self.log_message(
+                                    closed_event._id,
+                                    "Time limit reached! Please join the queue again.",
+                                    "info",
+                                    duration=10,
+                                )
+                                self.send_message(
+                                    closed_event,
+                                    ProcessCompletedMessage(output=response, success=True),
+                                )
                         if not awake_events:
                             break
                         body = cast(PredictBody, awake_events[0].data)

diff --git a/js/audio/player/AudioPlayer.svelte b/js/audio/player/AudioPlayer.svelte
@@ -43,7 +43,6 @@
 	let show_volume_slider = false;
 	let audio_player: HTMLAudioElement;
 
-	let audio_player: HTMLAudioElement;
 	let stream_active = false;
 
 	const dispatch = createEventDispatcher<{