fix lint

PeerDB-io · Dec 13, 2023 · 384cab3 · 384cab3
1 parent cc41a7b
commit 384cab3
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
@@ -139,9 +139,7 @@ func (c *EventHubConnector) processBatch(
 	batchPerTopic := NewHubBatches(c.hubManager)
 	toJSONOpts := model.NewToJSONOptions(c.config.UnnestColumns)
 
-	eventHubFlushTimeout :=
-		time.Duration(peerdbenv.GetPeerDBEventhubFlushTimeoutSeconds()) *
-			time.Second
+	eventHubFlushTimeout := peerdbenv.GetPeerDBEventhubFlushTimeoutSeconds()
 
 	ticker := time.NewTicker(eventHubFlushTimeout)
 	defer ticker.Stop()