Update sdk-go so we can support executor test for cloudevent (#1182)

Signed-off-by: Jian Qiu <[email protected]>

Author: qiujian16

go.mod

@@ -41,7 +41,7 @@ require (
 	k8s.io/utils v0.0.0-20241210054802-24370beab758
 	open-cluster-management.io/addon-framework v1.0.1-0.20250811135502-4bae358d84c6
 	open-cluster-management.io/api v1.0.1-0.20250903073454-c6702adf44cc
-	open-cluster-management.io/sdk-go v1.0.1-0.20250905083121-3fc951c340cc
+	open-cluster-management.io/sdk-go v1.0.1-0.20250911065113-bff262df709b
 	sigs.k8s.io/about-api v0.0.0-20250131010323-518069c31c03
 	sigs.k8s.io/cluster-inventory-api v0.0.0-20240730014211-ef0154379848
 	sigs.k8s.io/controller-runtime v0.21.0

go.sum

@@ -559,8 +559,8 @@ open-cluster-management.io/addon-framework v1.0.1-0.20250811135502-4bae358d84c6
 open-cluster-management.io/addon-framework v1.0.1-0.20250811135502-4bae358d84c6/go.mod h1:fOPWaRyo6upgHFskcL18Al1kI2Ua9HzrS8uothWEe84=
 open-cluster-management.io/api v1.0.1-0.20250903073454-c6702adf44cc h1:U8O6RhHjp088oWuQsGx6pwwFpOFgWo1gl9qhgIGgDpk=
 open-cluster-management.io/api v1.0.1-0.20250903073454-c6702adf44cc/go.mod h1:lEc5Wkc9ON5ym/qAtIqNgrE7NW7IEOCOC611iQMlnKM=
-open-cluster-management.io/sdk-go v1.0.1-0.20250905083121-3fc951c340cc h1:wi6w+Gi7MhGepfDFNN71JGc5jIsWWJOtcXJFQfHripM=
-open-cluster-management.io/sdk-go v1.0.1-0.20250905083121-3fc951c340cc/go.mod h1:JVQupKu0xVcuVP4IUJF7hjvrXK8plZiwGPZcdqngjXk=
+open-cluster-management.io/sdk-go v1.0.1-0.20250911065113-bff262df709b h1:tzgcM+yJJBgMwYYbjfzW4kL8p7bsHnScE5lS/69lksE=
+open-cluster-management.io/sdk-go v1.0.1-0.20250911065113-bff262df709b/go.mod h1:JVQupKu0xVcuVP4IUJF7hjvrXK8plZiwGPZcdqngjXk=
 sigs.k8s.io/about-api v0.0.0-20250131010323-518069c31c03 h1:1ShFiMjGQOR/8jTBkmZrk1gORxnvMwm1nOy2/DbHg4U=
 sigs.k8s.io/about-api v0.0.0-20250131010323-518069c31c03/go.mod h1:F1pT4mK53U6F16/zuaPSYpBaR7x5Kjym6aKJJC0/DHU=
 sigs.k8s.io/apiserver-network-proxy/konnectivity-client v0.31.2 h1:jpcvIRr3GLoUoEKRkHKSmGjxb6lWwrBlJsXc+eUYQHM=

test/integration-test.mk

@@ -54,24 +54,20 @@ test-addon-integration: ensure-kubebuilder-tools
 .PHONY: test-addon-integration
 
 # In the cloud events scenario, skip the following tests
-# - executor_test.go, this feature is not supported yet by cloud events work client
 # - unmanaged_appliedwork_test.go, this test mainly focus on switching the hub kube-apiserver
 # - manifestworkreplicaset_test.go, this test needs to update the work status with the hub work client,
 #   cloud events work client does not support it. (TODO) may add e2e to for mwrs.
 test-cloudevents-work-mqtt-integration: ensure-kubebuilder-tools build-work-integration
 	./work-integration.test -ginkgo.slow-spec-threshold=15s -ginkgo.v -ginkgo.fail-fast \
 		-ginkgo.skip-file manifestworkreplicaset_test.go \
-		-ginkgo.skip-file executor_test.go \
 		-ginkgo.skip-file unmanaged_appliedwork_test.go \
 		-test.driver=mqtt \
 		-v=4 ${ARGS}
 .PHONY: test-cloudevents-work-mqtt-integration
 
 # In the cloud events scenario, skip the following tests
-# - executor_test.go, this feature is not supported yet since the executor field is not in the manifestbundle.
 test-cloudevents-work-grpc-integration: ensure-kubebuilder-tools build-work-integration
 	./work-integration.test -ginkgo.slow-spec-threshold=15s -ginkgo.v -ginkgo.fail-fast \
-		-ginkgo.skip-file executor_test.go \
 		-test.driver=grpc \
 		-v=4 ${ARGS}
 .PHONY: test-cloudevents-work-grpc-integration

test/integration/work/executor_test.go

@@ -3,6 +3,7 @@ package work
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 
 	jsonpatch "github.com/evanphx/json-patch"
 	"github.com/onsi/ginkgo/v2"
@@ -58,8 +59,8 @@ var _ = ginkgo.Describe("ManifestWork Executor Subject", func() {
 	})
 
 	ginkgo.JustBeforeEach(func() {
-		work = util.NewManifestWork(clusterName, "", manifests)
-		gomega.Expect(err).ToNot(gomega.HaveOccurred())
+		workName := fmt.Sprintf("executor-work-%s", utilrand.String(5))
+		work = util.NewManifestWork(clusterName, workName, manifests)
 		work.Spec.Executor = executor
 	})
 

test/integration/work/suite_test.go

@@ -129,6 +129,7 @@ var _ = ginkgo.BeforeSuite(func() {
 
 		// start hub controller
 		go func() {
+			defer ginkgo.GinkgoRecover()
 			opts := hub.NewWorkHubManagerOptions()
 			opts.WorkDriver = "kube"
 			opts.WorkDriverConfig = sourceConfigFileName
@@ -172,6 +173,7 @@ var _ = ginkgo.BeforeSuite(func() {
 
 		// start hub controller
 		go func() {
+			defer ginkgo.GinkgoRecover()
 			// in grpc driver, hub controller still calls hub kube-apiserver.
 			sourceKubeConfigFileName := path.Join(tempDir, "kubeconfig")
 			err = util.CreateKubeconfigFile(cfg, sourceKubeConfigFileName)
@@ -223,6 +225,7 @@ type agentOptionsDecorator func(opt *spoke.WorkloadAgentOptions, commonOpt *comm
 	*spoke.WorkloadAgentOptions, *commonoptions.AgentOptions)
 
 func startWorkAgent(ctx context.Context, clusterName string, decorators ...agentOptionsDecorator) {
+	defer ginkgo.GinkgoRecover()
 	o := spoke.NewWorkloadAgentOptions()
 	o.StatusSyncInterval = 3 * time.Second
 	o.WorkloadSourceDriver = sourceDriver
@@ -261,7 +264,10 @@ func startGRPCServer(ctx context.Context, temp string, cfg *rest.Config) (string
 
 	hook, err := util.NewGRPCServerWorkHook(cfg)
 	gomega.Expect(err).NotTo(gomega.HaveOccurred())
-	go hook.Run(ctx)
+	go func() {
+		defer ginkgo.GinkgoRecover()
+		hook.Run(ctx)
+	}()
 
 	grpcEventServer := cloudeventsgrpc.NewGRPCBroker()
 	grpcEventServer.RegisterService(payload.ManifestBundleEventDataType,
@@ -277,6 +283,7 @@ func startGRPCServer(ctx context.Context, temp string, cfg *rest.Config) (string
 		WithExtraMetrics(cemetrics.CloudEventsGRPCMetrics()...)
 
 	go func() {
+		defer ginkgo.GinkgoRecover()
 		err := server.Run(ctx)
 		gomega.Expect(err).NotTo(gomega.HaveOccurred())
 	}()

vendor/modules.txt

@@ -1813,7 +1813,7 @@ open-cluster-management.io/api/operator/v1
 open-cluster-management.io/api/utils/work/v1/workapplier
 open-cluster-management.io/api/work/v1
 open-cluster-management.io/api/work/v1alpha1
-# open-cluster-management.io/sdk-go v1.0.1-0.20250905083121-3fc951c340cc
+# open-cluster-management.io/sdk-go v1.0.1-0.20250911065113-bff262df709b
 ## explicit; go 1.24.0
 open-cluster-management.io/sdk-go/pkg/apis/cluster/v1alpha1
 open-cluster-management.io/sdk-go/pkg/apis/cluster/v1beta1