Update pkg/index/job/exportation/service/exporter.go

Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com> Signed-off-by: s-shiraki <[email protected]>
vdaas · Dec 17, 2024 · 76dee08 · 76dee08
1 parent 247895e
commit 76dee08
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/index/job/exportation/service/exporter.go b/pkg/index/job/exportation/service/exporter.go
@@ -140,7 +140,8 @@ func (e *export) doExportIndex(
 	ctx, cancel := context.WithCancelCause(egctx)
 	gatewayAddrs := e.gateway.GRPCClient().ConnectedAddrs()
 	if len(gatewayAddrs) == 0 {
-		log.Errorf("Active gateway is not found.: %v ", ctx.Err())
+		log.Errorf("Active gateway is not found: %v", ctx.Err())
+		return errors.New("no active gateways available")
 	}
 
 	conn, err := grpc.NewClient(gatewayAddrs[0], grpc.WithTransportCredentials(insecure.NewCredentials()))