From 3cd0e17784818fba96fb78b15894a370c9303d4f Mon Sep 17 00:00:00 2001 From: Benoit Moriceau Date: Fri, 25 Oct 2024 12:47:08 -0700 Subject: [PATCH] chore: add file transfer log (#14466) --- .../io/airbyte/workers/internal/bookkeeping/StatsTracker.kt | 1 + 1 file changed, 1 insertion(+) diff --git a/airbyte-commons-worker/src/main/kotlin/io/airbyte/workers/internal/bookkeeping/StatsTracker.kt b/airbyte-commons-worker/src/main/kotlin/io/airbyte/workers/internal/bookkeeping/StatsTracker.kt index bb43bad1002..3c88f252ed8 100644 --- a/airbyte-commons-worker/src/main/kotlin/io/airbyte/workers/internal/bookkeeping/StatsTracker.kt +++ b/airbyte-commons-worker/src/main/kotlin/io/airbyte/workers/internal/bookkeeping/StatsTracker.kt @@ -118,6 +118,7 @@ class StreamStatsTracker( Jsons.getEstimatedByteSize(recordMessage.data).toLong() } else { recordMessage.additionalProperties["file"]?.let { + logger.info { "Received a file transfer record: $it" } val fileTransferInformations = Jsons.deserialize(Jsons.serialize(it), FileTransferInformations::class.java) fileTransferInformations.bytes } ?: Jsons.getEstimatedByteSize(recordMessage.data).toLong()