Fix queue_id parameter passing

- Pass queue_id to _assign_local_job method
- Fix NameError when assigning local jobs

vidai/cluster_master.py

@@ -539,7 +539,7 @@ class ClusterMaster:
         # Send job assignment
         if client_id == "local":
             # Handle local job assignment
-            return await self._assign_local_job(worker_key, job_data)
+            return await self._assign_local_job(worker_key, job_data, queue_id)
         elif client_id in self.client_websockets:
             try:
                 # Create the job assignment message
@@ -574,7 +574,7 @@ class ClusterMaster:
 
         return job_id
 
-    async def _assign_local_job(self, worker_key: str, job_data: dict) -> Optional[str]:
+    async def _assign_local_job(self, worker_key: str, job_data: dict, queue_id: int = None) -> Optional[str]:
         """Assign a job to a local worker."""
         from .models import estimate_model_vram_requirements