impulsivefps
/
EU-Utility
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: TaskManager accepts max_workers argument in __new__ 

- Updated TaskManager.__new__ to accept max_workers parameter
- Fixed get_task_manager to return TaskManager._instance directly
- This fixes the initialization error: 'TaskManager.new() got an unexpected keyword argument'
This commit is contained in:
LemonNexus 2026-02-16 00:46:28 +00:00
parent 80a92aa1ee
commit 01b001aa88
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
core/tasks.py
View File

@ -78,12 +78,13 @@ class TaskManager:
_instance = None _instance = None
_lock = threading.Lock() _lock = threading.Lock()
def __new__(cls): def __new__(cls, max_workers: int = 4):
if cls._instance is None: if cls._instance is None:
with cls._lock: with cls._lock:
if cls._instance is None: if cls._instance is None:
cls._instance = super().__new__(cls) cls._instance = super().__new__(cls)
cls._instance._initialized = False cls._instance._initialized = False
cls._instance._max_workers = max_workers
return cls._instance return cls._instance
def __init__(self, max_workers: int = 4): def __init__(self, max_workers: int = 4):
@ -354,4 +355,4 @@ def get_task_manager(max_workers: int = 4) -> TaskManager:
# Create with specified max_workers if not already created # Create with specified max_workers if not already created
if TaskManager._instance is None: if TaskManager._instance is None:
TaskManager(max_workers=max_workers) TaskManager(max_workers=max_workers)
return TaskManager() return TaskManager._instance