fix: defer

PeerDB-io · Sep 18, 2023 · 7e4376d · 7e4376d
1 parent 9ce405e
commit 7e4376d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
@@ -237,8 +237,8 @@ func (c *EventHubConnector) sendEventBatch(events map[string][]*eventhub.Event,
 			}).Infof("pushed %d events to event hub: %s",
 				numEventsPushed, tblName)
 			mapLock.Lock()
-			tableNameRowsMapping[tblName] += uint32(len(eventBatch))
 			defer mapLock.Unlock()
+			tableNameRowsMapping[tblName] += uint32(len(eventBatch))
 		}(tblName, eventBatch)
 	}