From 4cac1cde7e2a64af3877d9ff3a7d30818f0563be Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 1 Aug 2019 11:13:14 +0800 Subject: [PATCH] update shceduler_fair, bugfix --- src/scheduler_fair.go | 1 + 1 file changed, 1 insertion(+) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index b631be9..2f99a37 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -35,6 +35,7 @@ func (scheduler *SchedulerFair) Start() { scheduler.jobs = map[string]*JobManager{} scheduler.history = []*Job{} scheduler.nextQueue = "default" + scheduler.queues["default"] = []Job{} go func() { for {