lint

Author: PatStiles

core/retry_test.go

@@ -939,13 +939,13 @@ func TestSendSignedTaskResponse(t *testing.T) {
 
 	agg, err := aggregator.NewAggregator(*aggregatorConfig)
 	if err != nil {
-		fmt.Errorf("Could not load aggregator %s", err)
+		t.Errorf("Could not load aggregator %s", err)
 	}
 	ctx, cancel := context.WithCancel(context.Background())
 	go func() {
 		err = agg.Start(ctx)
 		if err != nil {
-			fmt.Errorf("Could not start Aggregator %s", err)
+			t.Errorf("Could not start Aggregator %s", err)
 		}
 	}()
 
@@ -954,7 +954,7 @@ func TestSendSignedTaskResponse(t *testing.T) {
 	// This is a mock to verify that a lost connection to the aggregator does not return anything.
 	disconnected_rpcClient, err := operator.NewAggregatorRpcClient("localhost:8999", logger)
 	if err != nil {
-		fmt.Errorf("Could not create RPC client: %s. Is aggregator running?", err)
+		t.Errorf("Could not create RPC client: %s. Is aggregator running?", err)
 	}
 
 	signedTaskResponse := &core_types.SignedTaskResponse{

operator/pkg/operator.go

@@ -349,7 +349,10 @@ func (o *Operator) handleNewBatchLogV2(newBatchLog *servicemanager.ContractAlign
 		hex.EncodeToString(signedTaskResponse.SenderAddress[:]),
 	)
 
-	o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)
+	_, err = o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)
+	if err != nil {
+		o.Logger.Infof("Failed to send signed task response %x to Aggregator. Err: %v", signedTaskResponse.BatchMerkleRoot, err)
+	}
 }
 func (o *Operator) ProcessNewBatchLogV2(newBatchLog *servicemanager.ContractAlignedLayerServiceManagerNewBatchV2) error {
 
@@ -430,7 +433,10 @@ func (o *Operator) handleNewBatchLogV3(newBatchLog *servicemanager.ContractAlign
 		hex.EncodeToString(signedTaskResponse.SenderAddress[:]),
 	)
 
-	o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)
+	_, err = o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)
+	if err != nil {
+		o.Logger.Infof("Failed to send signed task response %x to Aggregator. Err: %v", signedTaskResponse.BatchMerkleRoot, err)
+	}
 }
 func (o *Operator) ProcessNewBatchLogV3(newBatchLog *servicemanager.ContractAlignedLayerServiceManagerNewBatchV3) error {