From f03f4383afa131a965922d8ef882f49f6d6cc66f Mon Sep 17 00:00:00 2001 From: chrislu Date: Mon, 11 Aug 2025 02:19:22 -0700 Subject: [PATCH] fix missing grpc dial option --- weed/worker/worker.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/weed/worker/worker.go b/weed/worker/worker.go index ee834ac7a..d18d84193 100644 --- a/weed/worker/worker.go +++ b/weed/worker/worker.go @@ -14,6 +14,7 @@ import ( "github.com/seaweedfs/seaweedfs/weed/pb/worker_pb" "github.com/seaweedfs/seaweedfs/weed/worker/tasks" "github.com/seaweedfs/seaweedfs/weed/worker/types" + "google.golang.org/grpc" // Import task packages to trigger their auto-registration _ "github.com/seaweedfs/seaweedfs/weed/worker/tasks/ec_vacuum" @@ -446,6 +447,12 @@ func (w *Worker) executeTask(task *types.TaskInput) { return } + // Pass worker's gRPC dial option to task if it supports it + if grpcTask, ok := taskInstance.(interface{ SetGrpcDialOption(grpc.DialOption) }); ok { + grpcTask.SetGrpcDialOption(w.config.GrpcDialOption) + glog.V(2).Infof("Set gRPC dial option for task %s", task.ID) + } + // Task execution uses the new unified Task interface glog.V(2).Infof("Executing task %s in working directory: %s", task.ID, taskWorkingDir)