minor change

PeerDB-io · Nov 16, 2023 · 52f214f · 52f214f
1 parent 77693ab
commit 52f214f
Showing 1 changed file with 1 addition and 3 deletions.
diff --git 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
 	}