defers unlock

PeerDB-io · Sep 18, 2023 · 9ce405e · 9ce405e
1 parent ecb9f44
commit 9ce405e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
@@ -238,7 +238,7 @@ func (c *EventHubConnector) sendEventBatch(events map[string][]*eventhub.Event,
 				numEventsPushed, tblName)
 			mapLock.Lock()
 			tableNameRowsMapping[tblName] += uint32(len(eventBatch))
-			mapLock.Unlock()
+			defer mapLock.Unlock()
 		}(tblName, eventBatch)
 	}