Spaces:
Running
Running
Pulastya B commited on
Commit ·
5af048e
1
Parent(s): 06f2512
DEBUG: Log before queue.get() to see if loop executes
Browse files- src/api/app.py +1 -0
src/api/app.py
CHANGED
|
@@ -222,6 +222,7 @@ async def stream_progress(session_id: str):
|
|
| 222 |
|
| 223 |
# Stream new events from the queue
|
| 224 |
while True:
|
|
|
|
| 225 |
event = await queue.get()
|
| 226 |
print(f"[SSE] GOT event from queue: {event.get('type')}")
|
| 227 |
yield f"data: {json.dumps(event)}\n\n"
|
|
|
|
| 222 |
|
| 223 |
# Stream new events from the queue
|
| 224 |
while True:
|
| 225 |
+
print(f"[SSE] ABOUT TO CALL queue.get() - queue size: {queue.qsize()}")
|
| 226 |
event = await queue.get()
|
| 227 |
print(f"[SSE] GOT event from queue: {event.get('type')}")
|
| 228 |
yield f"data: {json.dumps(event)}\n\n"
|