add one more useful log

PeerDB-io · Nov 7, 2023 · 6a9cc99 · 6a9cc99
1 parent 1984f9f
commit 6a9cc99
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