fix: replace error type logs to warn type logs on telemetry (#1500)

Co-authored-by: Julian Ventura <[email protected]>

Author: JulianVentura

aggregator/pkg/telemetry.go

@@ -68,7 +68,7 @@ func (t *Telemetry) InitNewTrace(batchMerkleRoot [32]byte) {
 		MerkleRoot: fmt.Sprintf("0x%s", hex.EncodeToString(batchMerkleRoot[:])),
 	}
 	if err := t.sendTelemetryMessage("/api/initTaskTrace", body); err != nil {
-		t.logger.Error("[Telemetry] Error in InitNewTrace", "error", err)
+		t.logger.Warn("[Telemetry] Error in InitNewTrace", "error", err)
 	}
 }
 
@@ -78,7 +78,7 @@ func (t *Telemetry) LogOperatorResponse(batchMerkleRoot [32]byte, operatorId [32
 		OperatorId: fmt.Sprintf("0x%s", hex.EncodeToString(operatorId[:])),
 	}
 	if err := t.sendTelemetryMessage("/api/operatorResponse", body); err != nil {
-		t.logger.Error("[Telemetry] Error in LogOperatorResponse", "error", err)
+		t.logger.Warn("[Telemetry] Error in LogOperatorResponse", "error", err)
 	}
 }
 
@@ -87,7 +87,7 @@ func (t *Telemetry) LogQuorumReached(batchMerkleRoot [32]byte) {
 		MerkleRoot: fmt.Sprintf("0x%s", hex.EncodeToString(batchMerkleRoot[:])),
 	}
 	if err := t.sendTelemetryMessage("/api/quorumReached", body); err != nil {
-		t.logger.Error("[Telemetry] Error in LogQuorumReached", "error", err)
+		t.logger.Warn("[Telemetry] Error in LogQuorumReached", "error", err)
 	}
 }
 
@@ -97,7 +97,7 @@ func (t *Telemetry) LogTaskError(batchMerkleRoot [32]byte, taskError error) {
 		TaskError:  taskError.Error(),
 	}
 	if err := t.sendTelemetryMessage("/api/taskError", body); err != nil {
-		t.logger.Error("[Telemetry] Error in LogTaskError", "error", err)
+		t.logger.Warn("[Telemetry] Error in LogTaskError", "error", err)
 	}
 }
 
@@ -107,7 +107,7 @@ func (t *Telemetry) BumpedTaskGasPrice(batchMerkleRoot [32]byte, bumpedGasPrice
 		BumpedGasPrice: bumpedGasPrice,
 	}
 	if err := t.sendTelemetryMessage("/api/aggregatorTaskGasPriceBump", body); err != nil {
-		t.logger.Error("[Telemetry] Error in LogOperatorResponse", "error", err)
+		t.logger.Warn("[Telemetry] Error in LogOperatorResponse", "error", err)
 	}
 }
 
@@ -117,7 +117,7 @@ func (t *Telemetry) TaskSentToEthereum(batchMerkleRoot [32]byte, txHash string)
 		TxHash:     txHash,
 	}
 	if err := t.sendTelemetryMessage("/api/aggregatorTaskSent", body); err != nil {
-		t.logger.Error("[Telemetry] Error in TaskSentToEthereum", "error", err)
+		t.logger.Warn("[Telemetry] Error in TaskSentToEthereum", "error", err)
 	}
 }
 
@@ -129,15 +129,15 @@ func (t *Telemetry) FinishTrace(batchMerkleRoot [32]byte) {
 			MerkleRoot: fmt.Sprintf("0x%s", hex.EncodeToString(batchMerkleRoot[:])),
 		}
 		if err := t.sendTelemetryMessage("/api/finishTaskTrace", body); err != nil {
-			t.logger.Error("[Telemetry] Error in FinishTrace", "error", err)
+			t.logger.Warn("[Telemetry] Error in FinishTrace", "error", err)
 		}
 	}()
 }
 
 func (t *Telemetry) sendTelemetryMessage(endpoint string, message interface{}) error {
 	encodedBody, err := json.Marshal(message)
 	if err != nil {
-		t.logger.Error("[Telemetry] Error marshalling JSON", "error", err)
+		t.logger.Warn("[Telemetry] Error marshalling JSON", "error", err)
 		return fmt.Errorf("error marshalling JSON: %w", err)
 	}
 
@@ -147,14 +147,14 @@ func (t *Telemetry) sendTelemetryMessage(endpoint string, message interface{}) e
 
 	resp, err := t.client.Post(fullURL.String(), "application/json", bytes.NewBuffer(encodedBody))
 	if err != nil {
-		t.logger.Error("[Telemetry] Error sending POST request", "error", err)
+		t.logger.Warn("[Telemetry] Error sending POST request", "error", err)
 		return fmt.Errorf("error making POST request: %w", err)
 	}
 	defer resp.Body.Close()
 
 	respBody, err := io.ReadAll(resp.Body)
 	if err != nil {
-		t.logger.Error("[Telemetry] Error reading response body", "error", err)
+		t.logger.Warn("[Telemetry] Error reading response body", "error", err)
 		return fmt.Errorf("error reading response body: %w", err)
 	}
 

batcher/aligned-batcher/src/lib.rs

@@ -1253,7 +1253,7 @@ impl Batcher {
             .init_task_trace(&hex::encode(batch_merkle_tree.root))
             .await
         {
-            error!("Failed to initialize task trace on telemetry: {:?}", e);
+            warn!("Failed to initialize task trace on telemetry: {:?}", e);
         }
 
         if let Err(e) = self
@@ -1272,7 +1272,7 @@ impl Batcher {
                 .task_creation_failed(&hex::encode(batch_merkle_tree.root), &reason)
                 .await
             {
-                error!("Failed to send task status to telemetry: {:?}", e);
+                warn!("Failed to send task status to telemetry: {:?}", e);
             }
             for entry in finalized_batch.into_iter() {
                 if let Some(ws_sink) = entry.messaging_sink {
@@ -1396,7 +1396,7 @@ impl Batcher {
             .task_uploaded_to_s3(&batch_merkle_root_hex)
             .await
         {
-            error!("Failed to send task status to telemetry: {:?}", e);
+            warn!("Failed to send task status to telemetry: {:?}", e);
         };
         info!("Batch sent to S3 with name: {}", file_name);
 
@@ -1439,7 +1439,7 @@ impl Batcher {
             )
             .await
         {
-            error!("Failed to send task status to telemetry: {:?}", e);
+            warn!("Failed to send task status to telemetry: {:?}", e);
         };
 
         match self
@@ -1504,7 +1504,7 @@ impl Batcher {
                     .task_sent(&hex::encode(batch_merkle_root), receipt.transaction_hash)
                     .await
                 {
-                    error!("Failed to send task status to telemetry: {:?}", e);
+                    warn!("Failed to send task status to telemetry: {:?}", e);
                 }
                 Ok(receipt)
             }