update

server/worker.go

@@ -54,8 +54,13 @@ func workerResourceInfoKey(addr string) string {
 	return config.WORKER_RESOURCE_INFO_PREFIX + addr
 }
 
-func workerStatusKey(addr string, nonce int64) string {
-	return fmt.Sprintf("%s_%s_%d", config.WORKER_STATUS_PREFIX, addr, nonce)
+func workerStatusKey(addr string, nonce int) string {
+	id := workerId(addr, nonce)
+	return fmt.Sprintf("%s_%s", config.WORKER_STATUS_PREFIX, id)
+}
+
+func workerId(addr string, nonce int) string {
+	return fmt.Sprintf("%s_%d", addr, nonce)
 }
 
 func newManagerClient(endpoint string) (omanager.NodeManagerServiceClient, error) {