Add missing pending_jobs attribute to ClusterMaster

- Initialize self.pending_jobs dict for job monitoring tasks
- Fixes AttributeError when assigning local jobs
parent 42837adf
......@@ -60,6 +60,7 @@ class ClusterMaster:
self.active_jobs = {} # type: Dict[str, Dict[str, Any]] # job_id -> job info
self.worker_jobs = defaultdict(list) # type: Dict[str, List[str]] # worker_key -> [job_ids]
self.worker_vram_usage = defaultdict(int) # type: Dict[str, int] # worker_key -> current VRAM usage in GB
self.pending_jobs = {} # type: Dict[str, asyncio.Task] # job_id -> monitoring task
# Rate limiting for console messages
self.last_job_status_print = 0 # Timestamp of last job status message
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment