Add large queue fix

dora-rs · Oct 11, 2024 · 409edcd · 409edcd
1 parent a254d70
commit 409edcd
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/node-hub/dora-qwenvl/dora_qwenvl/main.py b/node-hub/dora-qwenvl/dora_qwenvl/main.py
@@ -101,6 +101,15 @@ def main():
         event_type = event["type"]
 
         if event_type == "INPUT":
+
+            # TODO: Remove this after https://github.com/dora-rs/dora/pull/652
+            while True:
+                next_event = node.next(timeout=0.001)
+                if next_event is not None and next_event["type"] == "INPUT":
+                    event = next_event
+                else:
+                    break
+
             event_id = event["id"]
 
             if "image" in event_id: