From 52f214f74afcfedf6589aaf49c685ef5203a0640 Mon Sep 17 00:00:00 2001
From: Amogh-Bharadwaj <amogh@peerdb.io>
Date: Fri, 17 Nov 2023 02:48:34 +0530
Subject: [PATCH] minor change

---
 flow/connectors/eventhub/eventhub.go | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
index 5821755cc0..e81a0c018c 100644
--- a/flow/connectors/eventhub/eventhub.go
+++ b/flow/connectors/eventhub/eventhub.go
@@ -164,9 +164,7 @@ func (c *EventHubConnector) processBatch(
 		"flowName": flowJobName,
 	}).Infof("processed %d records for sending", numRecords)
 
-	var flushErr error
-
-	flushErr = batchPerTopic.flushAllBatches(ctx, maxParallelism, flowJobName)
+	flushErr := batchPerTopic.flushAllBatches(ctx, maxParallelism, flowJobName)
 	if flushErr != nil {
 		return 0, flushErr
 	}