admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

[skip ci]Update pod kill chaos (#9818)

Browse Source 
Signed-off-by: zhuwenxing <wenxing.zhu@zilliz.com>
This commit is contained in:
zhuwenxing 2021-10-13 19:26:34 +08:00 committed by GitHub
parent 0d03a2066e
commit 1cd12e2b83
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 14 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
.github/workflows/pod-kill-chaos-test.yaml vendored
View File

@ -66,6 +66,9 @@ jobs:
sleep 20s
# check whether port-forward success
nc -vz 127.0.0.1 19530
# check whether milvus server is healthy
wget https://raw.githubusercontent.com/milvus-io/pymilvus/v2.0.0rc6/examples/hello_milvus.py
python hello_milvus.py
- name: Chaos Test
shell: bash
@ -74,7 +77,7 @@ jobs:
# replace chaos object
sed -i "s/ALL_CHAOS_YAMLS =.*/ALL_CHAOS_YAMLS = \'chaos_${{ matrix.pod }}_podkill.yaml\'/g" constants.py
cat constants.py
pytest -s -v test_chaos.py --host 127.0.0.1 --log-level=INFO --tb=no
pytest -s -v test_chaos.py --host 127.0.0.1
- name: Export logs
if: ${{ always() }}

20
tests/python_client/chaos/test_chaos.py
View File

@ -143,16 +143,16 @@ class TestChaos(TestChaosBase):
for k, t in self.checker_threads.items():
log.info(f"10s later: Thread {k} is_alive(): {t.is_alive()}")
# # assert statistic
# log.info("******2nd assert after chaos injected: ")
# assert_statistic(self.health_checkers,
# expectations={Op.create: self.expect_create,
# Op.insert: self.expect_insert,
# Op.flush: self.expect_flush,
# Op.index: self.expect_index,
# Op.search: self.expect_search,
# Op.query: self.expect_query
# })
# assert statistic
log.info("******2nd assert after chaos injected: ")
assert_statistic(self.health_checkers,
expectations={Op.create: self.expect_create,
Op.insert: self.expect_insert,
Op.flush: self.expect_flush,
Op.index: self.expect_index,
Op.search: self.expect_search,
Op.query: self.expect_query
})
# delete chaos
meta_name = chaos_config.get('metadata', None).get('name', None)