small cleanup

PeerDB-io · Jan 11, 2024 · 71f346d · 71f346d
1 parent 7741945
commit 71f346d
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
@@ -226,11 +226,9 @@ func (c *EventHubConnector) processBatch(
 }
 
 func (c *EventHubConnector) SyncRecords(req *model.SyncRecordsRequest) (*model.SyncResponse, error) {
-	var err error
 	batch := req.Records
-	var numRecords uint32
 
-	numRecords, err = c.processBatch(req.FlowJobName, batch)
+	numRecords, err := c.processBatch(req.FlowJobName, batch)
 	if err != nil {
 		c.logger.Error("failed to process batch", slog.Any("error", err))
 		return nil, err