Merge branch 'branch-24.10' of github.com:nv-morpheus/Morpheus into d…

…avid-contrib-conda-yaml-1660
nv-morpheus · Oct 19, 2024 · 63b9fcf · 63b9fcf
2 parents b9d5e07 + 5a2d71f
commit 63b9fcf
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/python/morpheus/morpheus/stages/input/http_server_source_stage.py b/python/morpheus/morpheus/stages/input/http_server_source_stage.py
@@ -248,7 +248,8 @@ def _generate_frames(self, subscription: mrc.Subscription) -> typing.Iterator[Me
                 # shutdown since we already returned an OK response to the client.
                 df = None
                 try:
-                    df = self._queue.get(block=False)
+                    # Intentionally not using self._queue_timeout here since that value is rather high
+                    df = self._queue.get(block=False, timeout=0.1)
                     self._queue_size -= 1
                 except queue.Empty:
                     if (not self._http_server.is_running() or self.is_stop_requested()