Fix golangci-lint errors

Signed-off-by: Sreekanth <[email protected]>

pkg/udf/forward/forward.go

@@ -481,7 +481,7 @@ func (isdf *InterStepDataForward) streamMessage(ctx context.Context, dataMessage
 	if len(dataMessages) > 1 {
 		errMsg := "data message size is not 1 with map UDF streaming"
 		isdf.opts.logger.Errorw(errMsg)
-		return nil, fmt.Errorf(errMsg)
+		return nil, errors.New(errMsg)
 	} else if len(dataMessages) == 1 {
 		// send to map UDF only the data messages
 

pkg/webhook/validator/validator.go

@@ -83,7 +83,10 @@ func GetValidator(ctx context.Context, NumaClient v1alpha1.NumaflowV1alpha1Inter
 
 // DeniedResponse constructs a denied AdmissionResponse
 func DeniedResponse(reason string, args ...interface{}) *admissionv1.AdmissionResponse {
-	result := apierrors.NewBadRequest(fmt.Sprintf(reason, args...)).Status()
+	if len(args) > 0 {
+		reason = fmt.Sprintf(reason, args)
+	}
+	result := apierrors.NewBadRequest(reason).Status()
 	return &admissionv1.AdmissionResponse{
 		Result:  &result,
 		Allowed: false,

test/transformer-e2e/transformer_test.go

@@ -173,7 +173,7 @@ func (s *TransformerSuite) TestSourceTransformer() {
 	}
 
 	var wg sync.WaitGroup
-	wg.Add(4)
+	wg.Add(1)
 	// FIXME: Enable these tests after corresponding SDKs are changed to support bidirectional streaming
 	//go func() {
 	//	defer wg.Done()