Skip to content

Commit d2c8f30

Browse files
committed
chore: add logs for debugging stats in bookkeeper mode (#16623)
1 parent 9c12320 commit d2c8f30

File tree

1 file changed

+7
-0
lines changed
  • airbyte-container-orchestrator/src/main/kotlin/io/airbyte/container/orchestrator/bookkeeping

1 file changed

+7
-0
lines changed

airbyte-container-orchestrator/src/main/kotlin/io/airbyte/container/orchestrator/bookkeeping/StatsTracker.kt

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -137,6 +137,7 @@ class StreamStatsTracker(
137137
if (!isBookkeeperMode) {
138138
return
139139
}
140+
logger.info { "Dummy stats message from destination $recordMessage" }
140141
val byteCount =
141142
recordMessage.additionalProperties[DEST_EMITTED_BYTES_COUNT]
142143
.asLongOrZero()
@@ -213,6 +214,9 @@ class StreamStatsTracker(
213214
* to keep on tracking incoming messages.
214215
*/
215216
fun trackStateFromSource(stateMessage: AirbyteStateMessage) {
217+
if (isBookkeeperMode) {
218+
logger.info { "State message from source $stateMessage" }
219+
}
216220
val currentTime = LocalDateTime.now()
217221
streamStats.sourceStateCount.incrementAndGet()
218222

@@ -272,6 +276,9 @@ class StreamStatsTracker(
272276
* said acked state.
273277
*/
274278
fun trackStateFromDestination(stateMessage: AirbyteStateMessage) {
279+
if (isBookkeeperMode) {
280+
logger.info { "State message from destination : $stateMessage" }
281+
}
275282
val currentTime = LocalDateTime.now()
276283
streamStats.destinationStateCount.incrementAndGet()
277284

0 commit comments

Comments
 (0)