Commit ee2980db authored by vicotor's avatar vicotor

update worker

parent c8adc3dd
...@@ -106,7 +106,7 @@ func withManager(idx int, endpoint string) { ...@@ -106,7 +106,7 @@ func withManager(idx int, endpoint string) {
for { for {
data, err := managerClient.Recv() data, err := managerClient.Recv()
if err != nil { if err != nil {
log.WithField("endpoint", endpoint).Fatal("register worker failed", "err", err) log.WithField("endpoint", endpoint).Error("register worker failed", "err", err)
return return
} }
switch b := data.Message.(type) { switch b := data.Message.(type) {
......
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