From 3998c8489e2f8e96a24a18afba84d1a4bd59de75 Mon Sep 17 00:00:00 2001 From: Benoit Moriceau Date: Mon, 28 Oct 2024 09:54:27 -0700 Subject: [PATCH] chore: log message send to destination for file transfer (#14474) --- .../io/airbyte/workers/general/BufferedReplicationWorker.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/airbyte-commons-worker/src/main/java/io/airbyte/workers/general/BufferedReplicationWorker.java b/airbyte-commons-worker/src/main/java/io/airbyte/workers/general/BufferedReplicationWorker.java index efeea44d03d..95791ce9e8f 100644 --- a/airbyte-commons-worker/src/main/java/io/airbyte/workers/general/BufferedReplicationWorker.java +++ b/airbyte-commons-worker/src/main/java/io/airbyte/workers/general/BufferedReplicationWorker.java @@ -431,7 +431,9 @@ private void writeToDestination() { if (message == null) { continue; } - + if (replicationInput.getUseFileTransfer()) { + LOGGER.info("writeToDestination: writing message to transfer file"); + } try (final var t = writeToDestStopwatch.start()) { destination.accept(message); }