Skip to content

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

update

parent a7903988
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 0 deletions
server/node.go
View file @ 8f1d135d
...@@ -373,6 +373,10 @@ func (n *Node) PopWorker(ctx context.Context, rdb *redis.Client, task *odysseus. ...@@ -373,6 +373,10 @@ func (n *Node) PopWorker(ctx context.Context, rdb *redis.Client, task *odysseus.
} }
log.WithField("elem", elem).Debug("lPop worker") log.WithField("elem", elem).Debug("lPop worker")
addr, nonce := parseWorkerId(elem) addr, nonce := parseWorkerId(elem)
log.WithFields(log.Fields{
"addr": addr,
"nonce": nonce,
}).Debug("parsed worker")
managerList, err := rdb.SMembers(context.Background(), workerStatusKey(addr, nonce)).Result() managerList, err := rdb.SMembers(context.Background(), workerStatusKey(addr, nonce)).Result()
if err != nil { if err != nil {
log.WithError(err).Error("get worker status failed") log.WithError(err).Error("get worker status failed")
......
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