Files
robertvoy-ComfyUI-Distributed/workers/__init__.py

12 lines
326 B
Python

from .process_manager import WorkerProcessManager
_worker_manager: WorkerProcessManager | None = None
def get_worker_manager() -> WorkerProcessManager:
global _worker_manager
if _worker_manager is None:
_worker_manager = WorkerProcessManager()
_worker_manager.queues = {}
return _worker_manager