diff options
Diffstat (limited to 'src/worker_ws.rs')
| -rw-r--r-- | src/worker_ws.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/worker_ws.rs b/src/worker_ws.rs index fa43721..b057ca1 100644 --- a/src/worker_ws.rs +++ b/src/worker_ws.rs @@ -303,8 +303,8 @@ impl State { pub fn dispatch_work(&mut self) { let mut to_send = Vec::new(); for (id, w) in &mut self.workers { - if w.accept >= 1 { - for kind in &w.task_kinds { + for kind in &w.task_kinds { + if w.accept > 0 { let prefix = format!("{kind}:"); let Some(first) = self.queue.iter().find(|e| e.starts_with(&prefix)).cloned() else { |