Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
milvus
milvus
提交
f55ca5eb
M
milvus
项目概览
milvus
/
milvus
12 个月 前同步成功
通知
261
Star
22476
Fork
2472
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
M
milvus
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
未验证
提交
f55ca5eb
编写于
6月 27, 2022
作者:
Z
zhuwenxing
提交者:
GitHub
6月 27, 2022
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[skip e2e]Update multi replicas chaos (#17831)
Signed-off-by:
N
zhuwenxing
<
wenxing.zhu@zilliz.com
>
上级
f0b036a3
变更
1
显示空白变更内容
内联
并排
Showing
1 changed file
with
8 addition
and
2 deletion
+8
-2
tests/python_client/chaos/test_chaos_multi_replicas.py
tests/python_client/chaos/test_chaos_multi_replicas.py
+8
-2
未找到文件。
tests/python_client/chaos/test_chaos_multi_replicas.py
浏览文件 @
f55ca5eb
...
...
@@ -12,7 +12,7 @@ from chaos.checker import (InsertFlushChecker, SearchChecker, QueryChecker, Op)
from
common.cus_resource_opts
import
CustomResourceOperations
as
CusResource
from
common.milvus_sys
import
MilvusSys
from
utils.util_log
import
test_log
as
log
from
utils.util_k8s
import
wait_pods_ready
,
get_pod_ip_name_pairs
from
utils.util_k8s
import
wait_pods_ready
,
get_pod_ip_name_pairs
,
get_milvus_instance_name
from
chaos
import
chaos_commons
as
cc
from
common.common_type
import
CaseLabel
from
common
import
common_func
as
cf
...
...
@@ -82,6 +82,7 @@ class TestChaos(TestChaosBase):
raise
Exception
(
"no connections"
)
self
.
host
=
host
self
.
port
=
port
self
.
instance_name
=
get_milvus_instance_name
(
constants
.
CHAOS_NAMESPACE
,
host
)
@
pytest
.
fixture
(
scope
=
"function"
,
autouse
=
True
)
def
init_health_checkers
(
self
):
...
...
@@ -113,13 +114,15 @@ class TestChaos(TestChaosBase):
def
test_multi_replicas_with_only_one_group_available
(
self
,
chaos_type
,
failed_node_type
,
failed_group_scope
,
is_streaming
):
# start the monitor threads to check the milvus ops
log
.
info
(
"*********************Chaos Test Start**********************"
)
log
.
info
(
"Test config"
)
log
.
info
(
cc
.
gen_experiment_config
(
config_file_name
))
# log.info(f"chaos_yaml: {chaos_yaml}")
log
.
info
(
connections
.
get_connection_addr
(
'default'
))
if
is_streaming
is
False
:
del
self
.
health_checkers
[
Op
.
insert
]
cc
.
start_monitor_threads
(
self
.
health_checkers
)
# get replicas info
release_name
=
"milvus-multi-querynode"
release_name
=
self
.
instance_name
querynode_id_pod_pair
=
get_querynode_info
(
release_name
)
log
.
info
(
querynode_id_pod_pair
)
group_list
=
[]
...
...
@@ -146,6 +149,9 @@ class TestChaos(TestChaosBase):
target_nodes
=
list
(
set
(
g
)
&
set
(
shard_leader_list
))
if
failed_node_type
==
"non_shard_leader"
:
target_nodes
=
list
(
set
(
g
)
-
set
(
shard_leader_list
))
if
len
(
target_nodes
)
==
0
:
log
.
info
(
"there is no node satisfied, chose one randomly"
)
target_nodes
=
[
random
.
choice
(
g
)]
for
target_node
in
target_nodes
:
pod
=
querynode_id_pod_pair
[
target_node
]
target_pod_list
.
append
(
pod
)
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录