diff --git a/worker/task.go b/worker/task.go index 28ab6cc9734f8cf3a65bc5b73d58115fd1b8f747..e6e2f7eee6ec431171e4f690cb076a983dc0b9be 100644 --- a/worker/task.go +++ b/worker/task.go @@ -56,7 +56,8 @@ func ProcessTaskOverNetwork(qu []byte) (result []byte, rerr error) { query.Data = qu reply := new(conn.Reply) if err := pool.Call("Worker.ServeTask", query, reply); err != nil { - glog.WithField("call", "Worker.ServeTask").Fatal(err) + glog.WithField("call", "Worker.ServeTask").Error(err) + return []byte(""), err } glog.WithField("reply_len", len(reply.Data)).WithField("addr", addr). WithField("attr", attr).Info("Got reply from server")