no need to requeue if resource is not found.

Signed-off-by: morvencao <lcao@redhat.com>
openshift-online · Jan 2, 2025 · eb7c030 · eb7c030
1 parent 29902c2
commit eb7c030
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/cmd/maestro/server/grpc_broker.go b/cmd/maestro/server/grpc_broker.go
@@ -418,6 +418,10 @@ func (bkr *GRPCBroker) handleRes(resource *api.Resource) error {
 func (bkr *GRPCBroker) OnCreate(ctx context.Context, id string) error {
 	resource, err := bkr.resourceService.Get(ctx, id)
 	if err != nil {
+		// if the resource is not found, it indicates the resource has been processed.
+		if err.Is404() {
+			return nil
+		}
 		return err
 	}
 
@@ -428,6 +432,10 @@ func (bkr *GRPCBroker) OnCreate(ctx context.Context, id string) error {
 func (bkr *GRPCBroker) OnUpdate(ctx context.Context, id string) error {
 	resource, err := bkr.resourceService.Get(ctx, id)
 	if err != nil {
+		// if the resource is not found, it indicates the resource has been processed.
+		if err.Is404() {
+			return nil
+		}
 		return err
 	}
 
@@ -438,6 +446,10 @@ func (bkr *GRPCBroker) OnUpdate(ctx context.Context, id string) error {
 func (bkr *GRPCBroker) OnDelete(ctx context.Context, id string) error {
 	resource, err := bkr.resourceService.Get(ctx, id)
 	if err != nil {
+		// if the resource is not found, it indicates the resource has been processed.
+		if err.Is404() {
+			return nil
+		}
 		return err
 	}