Skip to content

Commit 0172105

Browse files
committed
k8s: add optional ns to wait_for_pod
1 parent b567511 commit 0172105

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/warnet/k8s.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -348,10 +348,12 @@ def pod_log(pod_name, container_name=None, follow=False, namespace: Optional[str
348348
raise Exception(json.loads(e.body.decode("utf-8"))["message"]) from None
349349

350350

351-
def wait_for_pod(pod_name, timeout_seconds=10):
351+
def wait_for_pod(pod_name, timeout_seconds=10, namespace: Optional[str] = None):
352+
if not namespace:
353+
namespace = get_default_namespace()
352354
sclient = get_static_client()
353355
while timeout_seconds > 0:
354-
pod = sclient.read_namespaced_pod_status(name=pod_name, namespace=get_default_namespace())
356+
pod = sclient.read_namespaced_pod_status(name=pod_name, namespace=namespace)
355357
if pod.status.phase != "Pending":
356358
return
357359
sleep(1)

0 commit comments

Comments
 (0)