Commit 7109576
feat: add weighted fair queuing scheduler
Introduces a scheduler with four layered admission constraints:
- Total concurrency: hard global cap on running jobs
- Priority tiers: weighted share of total concurrency per tier
(Priority struct with Level + Weight)
- Per-type limits: fraction of tier slots per job type
- Conflict groups: mutual exclusion by group + job ID
Within a tier, jobs are ordered by accumulated cost per fairness
key (lowest first), with cost estimated via EMA of wall time.
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>1 parent 6fbc1c6 commit 7109576
6 files changed
Lines changed: 1951 additions & 0 deletions
File tree
- internal/scheduler
0 commit comments