Missing last ipv6 conversion.

airbytehq · Mar 22, 2024 · 6dad0c1 · 6dad0c1
1 parent 7d31875
commit 6dad0c1
Showing 1 changed file with 5 additions and 1 deletion.
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
@@ -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,