Skip to content

Commit fd94d28

Browse files
committed
chore: print container and pod info for monopod. (#13915)
1 parent cfdad4e commit fd94d28

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

airbyte-workload-launcher/src/main/kotlin/pods/KubePodClient.kt

+8
Original file line numberDiff line numberDiff line change
@@ -34,12 +34,15 @@ import io.airbyte.workload.launcher.pods.factories.OrchestratorPodFactory
3434
import io.airbyte.workload.launcher.pods.factories.ReplicationPodFactory
3535
import io.fabric8.kubernetes.api.model.Pod
3636
import io.fabric8.kubernetes.client.KubernetesClientTimeoutException
37+
import io.github.oshai.kotlinlogging.KotlinLogging
3738
import jakarta.inject.Named
3839
import jakarta.inject.Singleton
3940
import java.time.Duration
4041
import java.util.UUID
4142
import java.util.concurrent.TimeoutException
4243

44+
private val logger = KotlinLogging.logger {}
45+
4346
/**
4447
* Interface layer between domain and Kube layers.
4548
* Composes raw Kube layer atomic operations to perform business operations.
@@ -147,6 +150,11 @@ class KubePodClient(
147150
replicationInput.connectionId,
148151
)
149152

153+
logger.info { "Launching replication pod: ${kubeInput.podName} with containers:" }
154+
logger.info { "[source] image: ${kubeInput.sourceImage} resources: ${kubeInput.sourceReqs}" }
155+
logger.info { "[destination] image: ${kubeInput.destinationImage} resources: ${kubeInput.destinationReqs}" }
156+
logger.info { "[orchestrator] image: ${kubeInput.orchestratorImage} resources: ${kubeInput.orchestratorReqs}" }
157+
150158
try {
151159
pod =
152160
kubePodLauncher.create(pod)

0 commit comments

Comments
 (0)