Fix job assignment for restarted jobs

- Allow local jobs to start even if worker socket check fails
- Backend handles worker availability, queue manager should always allow local processing
parent 599fa8f3
...@@ -127,20 +127,9 @@ class QueueManager: ...@@ -127,20 +127,9 @@ class QueueManager:
if self._has_distributed_worker(process_type): if self._has_distributed_worker(process_type):
return True return True
# Check for local worker # For local processing, always allow if no distributed workers
if request_type == 'analyze': # The backend will handle worker availability
backend = get_analysis_backend() return True
worker_key_local = f'analysis_{backend}'
elif request_type == 'train':
backend = get_training_backend()
worker_key_local = f'training_{backend}'
else:
return False
if worker_key_local in worker_sockets:
return True
return False
def _has_distributed_worker(self, process_type: str) -> bool: def _has_distributed_worker(self, process_type: str) -> bool:
"""Check if there is a distributed worker available for the process type.""" """Check if there is a distributed worker available for the process type."""
......
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