From 1f6face022c9270886ec4b4543bf637810133d95 Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 1 Aug 2019 11:14: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 2f99a37..2a82c95 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 = map[string][]Job{} scheduler.queues["default"] = []Job{} go func() {