Update app.py
Browse files
app.py
CHANGED
|
@@ -42,7 +42,7 @@ def queue_processor():
|
|
| 42 |
"""Process tasks in the queue"""
|
| 43 |
while running:
|
| 44 |
try:
|
| 45 |
-
task_id, input_data, request_time = task_queue.get(timeout=
|
| 46 |
with lock:
|
| 47 |
task_status[task_id]['status'] = 'processing'
|
| 48 |
task_status[task_id]['start_time'] = time.time()
|
|
|
|
| 42 |
"""Process tasks in the queue"""
|
| 43 |
while running:
|
| 44 |
try:
|
| 45 |
+
task_id, input_data, request_time = task_queue.get(timeout=3)
|
| 46 |
with lock:
|
| 47 |
task_status[task_id]['status'] = 'processing'
|
| 48 |
task_status[task_id]['start_time'] = time.time()
|