Merge pull request #890 from stacklok/fix-reconciler

fix watermill error loop
mindersec · Sep 7, 2023 · a9e7577 · a9e7577
2 parents e56ea82 + 4416a50
commit a9e7577
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/internal/reconcilers/artifacts.go b/internal/reconcilers/artifacts.go
@@ -83,7 +83,7 @@ func (e *Reconciler) handleRepoReconcilerEvent(msg *message.Message) error {
 
 	// validate event
 	validate := validator.New()
-	if err := validate.Struct(evt); err != nil {
+	if err := validate.Struct(&evt); err != nil {
 		// We don't return the event since there's no use
 		// retrying it if it's invalid.
 		log.Printf("error validating event: %v", err)

diff --git a/pkg/controlplane/handlers_policy.go b/pkg/controlplane/handlers_policy.go
@@ -216,7 +216,7 @@ func (s *Server) CreatePolicy(ctx context.Context,
 	}
 
 	// This is a non-fatal error, so we'll just log it and continue with the next ones
-	if err := s.evt.Publish(reconcilers.InternalReconcilerEventTopic, msg); err != nil {
+	if err := s.evt.Publish(reconcilers.InternalPolicyInitEventTopic, msg); err != nil {
 		log.Printf("error publishing reconciler event: %v", err)
 	}