Spaces:
Runtime error
Runtime error
重複かつ非同期で不具合を起こしていたgetTaskOrderを消去
Browse files
app.py
CHANGED
@@ -102,6 +102,7 @@ def worker():
|
|
102 |
try:
|
103 |
task = task_queue.get()
|
104 |
if task.task_id in active_tasks:
|
|
|
105 |
future = executor.submit(process_task, task)
|
106 |
task_futures[task.task_id] = future
|
107 |
except Exception as e:
|
@@ -149,7 +150,7 @@ def submit_task():
|
|
149 |
|
150 |
# クライアントIPアドレスを取得
|
151 |
client_ip = get_remote_address()
|
152 |
-
client_id = session.get("sid")
|
153 |
|
154 |
# 同一IPからの同時タスク数を制限
|
155 |
if tasks_per_client.get(client_ip, 0) >= 2:
|
|
|
102 |
try:
|
103 |
task = task_queue.get()
|
104 |
if task.task_id in active_tasks:
|
105 |
+
print(f"Processing task {task.task_id}")
|
106 |
future = executor.submit(process_task, task)
|
107 |
task_futures[task.task_id] = future
|
108 |
except Exception as e:
|
|
|
150 |
|
151 |
# クライアントIPアドレスを取得
|
152 |
client_ip = get_remote_address()
|
153 |
+
# client_id = session.get("sid")
|
154 |
|
155 |
# 同一IPからの同時タスク数を制限
|
156 |
if tasks_per_client.get(client_ip, 0) >= 2:
|