Spaces:
Runtime error
Runtime error
da03
commited on
Commit
·
72b1ee4
1
Parent(s):
6454884
main.py
CHANGED
|
@@ -251,8 +251,9 @@ async def websocket_endpoint(websocket: WebSocket):
|
|
| 251 |
else:
|
| 252 |
# No interesting events - just take the most recent movement
|
| 253 |
next_input = input_queue[-1]
|
|
|
|
| 254 |
input_queue = []
|
| 255 |
-
print(f"Processing latest movement (skipped {
|
| 256 |
|
| 257 |
# Process the selected input asynchronously
|
| 258 |
asyncio.create_task(process_input(next_input))
|
|
|
|
| 251 |
else:
|
| 252 |
# No interesting events - just take the most recent movement
|
| 253 |
next_input = input_queue[-1]
|
| 254 |
+
skipped_count = len(input_queue) - 1 # We're processing one, so skipped = total - 1
|
| 255 |
input_queue = []
|
| 256 |
+
print(f"Processing latest movement (skipped {skipped_count} events)")
|
| 257 |
|
| 258 |
# Process the selected input asynchronously
|
| 259 |
asyncio.create_task(process_input(next_input))
|