Skip to content

S
scheduler
Commit 599bbdfe authored by vicotor's avatar vicotor
Browse files
Options

update priority

parent 279093bb
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
cmd/scheduler/rootcmd.go
View file @ 599bbdfe
...@@ -69,12 +69,12 @@ func initConfig() { ...@@ -69,12 +69,12 @@ func initConfig() {
} }
func runNode() { func runNode() {
go metrics.StartMetrics()
node := server.NewNode() node := server.NewNode()
err := node.Start() err := node.Start()
if err != nil { if err != nil {
log.WithError(err).Fatal("node start failed") log.WithError(err).Fatal("node start failed")
} }
metrics.StartMetrics()
wg := sync.WaitGroup{} wg := sync.WaitGroup{}
wg.Add(1) wg.Add(1)
......
server/worker.go
View file @ 599bbdfe
...@@ -17,7 +17,7 @@ import ( ...@@ -17,7 +17,7 @@ import (
) )
var ( var (
maxPriority = 1 // total priority for worker queue maxPriority = 2 // total priority for worker queue
) )
var ( var (
......
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