Tracking total records in EH connector (#404)

- Adds table mapping to Eventhub syncrecords return body for catalog metrics
PeerDB-io · Sep 21, 2023 · 6126e64 · 6126e64
1 parent 0e85c76
commit 6126e64
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
@@ -182,6 +182,7 @@ func (c *EventHubConnector) SyncRecords(req *model.SyncRecordsRequest) (*model.S
 		FirstSyncedCheckPointID: batch.FirstCheckPointID,
 		LastSyncedCheckPointID:  batch.LastCheckPointID,
 		NumRecordsSynced:        int64(len(batch.Records)),
+		TableNameRowsMapping:    tableNameRowsMapping,
 	}, nil
 }