diff --git a/airbyte-commons-worker/src/main/java/io/airbyte/workers/process/KubePodProcess.java b/airbyte-commons-worker/src/main/java/io/airbyte/workers/process/KubePodProcess.java
index 9fec2ddb255..2d00e882e13 100644
--- a/airbyte-commons-worker/src/main/java/io/airbyte/workers/process/KubePodProcess.java
+++ b/airbyte-commons-worker/src/main/java/io/airbyte/workers/process/KubePodProcess.java
@@ -188,7 +188,11 @@ public static String getPodIP(final KubernetesClient client, final String podNam
     if (pod == null) {
       throw new RuntimeException(prependPodInfo("Error: unable to find pod!", podNamespace, podName));
     }
-    return pod.getStatus().getPodIP();
+    if (pod.getStatus().getPodIP().contains(":")) {
+      return "[" + pod.getStatus().getPodIP() + "]";
+    } else {
+      return pod.getStatus().getPodIP();
+    }
   }
 
   private static Container getInit(final boolean usesStdin,