Skip to content

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

update

parent 9b5a6bb4
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
server/node.go
View file @ 03496321
...@@ -170,7 +170,7 @@ func (n *Node) Loop(idx int) { ...@@ -170,7 +170,7 @@ func (n *Node) Loop(idx int) {
l.WithError(err).Error("pop worker failed") l.WithError(err).Error("pop worker failed")
continue continue
} }
err = DispatchTask(worker, task) err = DispatchTask(n.rdb, worker, task)
if err != nil { if err != nil {
l.WithError(err).Error("dispatch task failed") l.WithError(err).Error("dispatch task failed")
continue continue
......
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