Skip to content

Commit 5fed029

Browse files
committed
fix: log image name (#14877)
1 parent 4d3d502 commit 5fed029

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

airbyte-commons-worker/src/main/java/io/airbyte/workers/general/ReplicationWorkerFactory.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,7 @@ public BufferedReplicationWorker create(final ReplicationInput replicationInput,
162162
final DestinationTimeoutMonitor destinationTimeout = createDestinationTimeout(featureFlagClient, replicationInput, metricClient);
163163
final RecordSchemaValidator recordSchemaValidator = createRecordSchemaValidator(replicationInput);
164164

165-
log.info("Setting up source...");
165+
log.info("Setting up source with image {}.", replicationInput.getSourceLauncherConfig().getDockerImage());
166166
final boolean printLongRecordPks = featureFlagClient.boolVariation(PrintLongRecordPks.INSTANCE,
167167
new Multi(List.of(
168168
new Connection(sourceLauncherConfig.getConnectionId()),
@@ -178,7 +178,7 @@ public BufferedReplicationWorker create(final ReplicationInput replicationInput,
178178
new MessageMetricsTracker(metricClient),
179179
ContainerIOHandle.source());
180180

181-
log.info("Setting up destination...");
181+
log.info("Setting up destination with image {}.", replicationInput.getDestinationLauncherConfig().getDockerImage());
182182
final AirbyteMessageBufferedWriterFactory messageWriterFactory =
183183
new VersionedAirbyteMessageBufferedWriterFactory(serDeProvider, migratorFactory, destinationLauncherConfig.getProtocolVersion(),
184184
Optional.of(replicationInput.getCatalog()));

0 commit comments

Comments
 (0)