milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[skip ci] Add comment to util k8s method (#12681) 

Signed-off-by: ThreadDao <yufen.zong@zilliz.com>
pull/12694/head
ThreadDao 2021-12-03 13:35:59 +08:00 committed by GitHub
parent d1aeed2802
commit e8b87400f4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
tests/python_client/utils/util_k8s.py
View File

@ -5,7 +5,21 @@ from utils.util_log import test_log as log
def wait_pods_ready(namespace, label_selector, timeout=360):
"""wait pods with label selector all ready"""
"""
wait pods with label selector all ready
:param namespace: the namespace where the release
:type namespace: str
:param label_selector: labels to restrict which pods are waiting to be ready
:type label_selector: str
:param timeout: limits the duration of the call
:type timeout: int
:example:
>>> wait_pods_ready("default", "app.kubernetes.io/instance=scale-query")
"""
config.load_kube_config()
api_instance = client.CoreV1Api()
try:
@ -27,7 +41,7 @@ def wait_pods_ready(namespace, label_selector, timeout=360):
if all_pos_ready_flag:
log.info(f"all pods in namespace {namespace} with label {label_selector} are ready")
else:
log.info("timeout for waiting all pods in namespace {namespace} with label {label_selector} ready")
log.info(f"timeout for waiting all pods in namespace {namespace} with label {label_selector} ready")
except ApiException as e:
log.error("Exception when calling CoreV1Api->list_namespaced_pod: %s\n" % e)
raise Exception(str(e))