🐛 fix(worker): initialize metrics query channel

1 month ago · d981da9251
1 changed files with 1 additions and 0 deletions
--- a/weed/worker/worker.go
+++ b/weed/worker/worker.go
@ -245,6 +245,7 @@ func (w *Worker) Start() error {
 	w.comms.taskReqs = make(chan taskRequest)
 	w.comms.taskCompl = make(chan taskCompletion)
 	w.comms.loadQuery = make(chan chan int)
+	w.comms.metricsQuery = make(chan chan metricsResponse)

 	// Prepare worker info for registration
 	workerInfo := &types.WorkerData{