karma/crab-webapp
1
0
Fork 0
mirror of https://github.com/karma-riuk/crab-webapp.git synced 2025-07-05 14:18:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

added way to show raised excpetions during thread

Browse Source 
execution
This commit is contained in:
Karma Riuk
2025-06-11 09:27:46 +02:00
parent ba25d6b28c
commit 47cefc955c
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/utils/queue_manager.py
View File

@ -1,6 +1,7 @@
from concurrent.futures import ThreadPoolExecutor from concurrent.futures import Future, ThreadPoolExecutor
from collections import deque from collections import deque
from utils.observer import Subject, Status from utils.observer import Subject, Status
import traceback
class QueueManager: class QueueManager:
@ -18,7 +19,15 @@ class QueueManager:
# Add to waiting queue # Add to waiting queue
self.wait_queue.append(subject.id) self.wait_queue.append(subject.id)
# Schedule the task on the executor # Schedule the task on the executor
self.executor.submit(self._run, subject, *args, **kwargs) future = self.executor.submit(self._run, subject, *args, **kwargs)
future.add_done_callback(self._on_task_done)
def _on_task_done(self, fut: Future) -> None:
exc = fut.exception()
if exc is not None:
# print exception and stack
print(f"\n[ERROR] Task “{fut}” raised an exception:")
traceback.print_exception(type(exc), exc, exc.__traceback__)
def get_position(self, subject_id: str) -> int: def get_position(self, subject_id: str) -> int:
""" """