add one more useful log

PeerDB-io · Nov 7, 2023 · e98dbaf · e98dbaf
1 parent e7893aa
commit e98dbaf
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
@@ -178,6 +178,10 @@ func (c *EventHubConnector) processBatch(
 		}
 	}
 
+	log.WithFields(log.Fields{
+		"flowName": flowJobName,
+	}).Infof("processed %d records for sending", numRecords)
+
 	err := flushBatch()
 	if err != nil {
 		return 0, err