diff --git a/python/morpheus/morpheus/stages/input/http_server_source_stage.py b/python/morpheus/morpheus/stages/input/http_server_source_stage.py
index 0459a458e4..c286c2dcd2 100644
--- 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()