diff --git a/fly/processor/observation_gossip_consumer.go b/fly/processor/observation_gossip_consumer.go
index 88f40c26..f8d634e3 100644
--- a/fly/processor/observation_gossip_consumer.go
+++ b/fly/processor/observation_gossip_consumer.go
@@ -113,22 +113,15 @@ func (c *observationGossipConsumer) process(ctx context.Context, o *gossipv1.Sig
 	go func(consumer *observationGossipConsumer, ctx context.Context, obs *gossipv1.SignedObservation) {
 		err = consumer.txHashStore.SetObservation(ctx, obs)
 		if err != nil {
-			consumer.logger.Error("Error setting txHash", zap.String("id", o.MessageId), zap.Error(err))
-		}
-	}(c, ctx, o)
-
-	go func(consumer *observationGossipConsumer, ctx context.Context, obs *gossipv1.SignedObservation) {
-		err = c.observationProcess(ctx, o)
-		if err != nil {
-			c.logger.Error("Error processing observation", zap.String("id", o.MessageId), zap.Error(err))
-			// This is the fallback to store the observation in the repository.
-			err = consumer.repository.UpsertObservation(ctx, obs, false)
-			if err != nil {
-				consumer.logger.Error("Error inserting observation in repository", zap.String("id", o.MessageId), zap.Error(err))
-			}
+			consumer.logger.Error("Error setting txHash", zap.String("id", obs.MessageId), zap.Error(err))
 		}
 	}(c, ctx, o)
 
+	// This is the fallback to store the observation in the repository.
+	err = c.repository.UpsertObservation(ctx, o, false)
+	if err != nil {
+		c.logger.Error("Error inserting observation in repository", zap.String("id", o.MessageId), zap.Error(err))
+	}
 }
 
 func (c *observationGossipConsumer) verifyObservation(obs *gossipv1.SignedObservation) bool {
@@ -151,7 +144,7 @@ func (c *observationGossipConsumer) verifyObservation(obs *gossipv1.SignedObserv
 
 	_, isFromGuardian := c.gst.Get().KeyIndex(theirAddr)
 	if !isFromGuardian {
-		c.logger.Error("error validating observation, signer not in guardian set",
+		c.logger.Debug("error validating observation, signer not in guardian set",
 			zap.String("id", obs.MessageId),
 			zap.String("obs_addr", theirAddr.Hex()),
 		)