admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-07 09:38:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add a nightly pipeline to test authentication (#23887)

Browse Source 
Signed-off-by: nico <cheng.yuan@zilliz.com>
This commit is contained in:
nico 2023-05-29 17:03:28 +08:00 committed by GitHub
parent 6375236533
commit 5eec886f74
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 28 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
ci/jenkins/Nightly.groovy
View File

@ -87,7 +87,7 @@ pipeline {
axes { axes {
axis { axis {
name 'MILVUS_SERVER_TYPE' name 'MILVUS_SERVER_TYPE'
values 'standalone', 'distributed-pulsar', 'distributed-kafka' values 'standalone', 'distributed-pulsar', 'distributed-kafka', 'standalone-authentication'
} }
axis { axis {
name 'MILVUS_CLIENT' name 'MILVUS_CLIENT'
@ -107,6 +107,7 @@ pipeline {
// def setMemoryResourceLimitArgs="--set standalone.resources.limits.memory=4Gi" // def setMemoryResourceLimitArgs="--set standalone.resources.limits.memory=4Gi"
def mqMode='pulsar' // default using is pulsar def mqMode='pulsar' // default using is pulsar
def mysql_architecture = "standalone" def mysql_architecture = "standalone"
def authenticationEnabled = "false"
if ("${MILVUS_SERVER_TYPE}" == "distributed-pulsar") { if ("${MILVUS_SERVER_TYPE}" == "distributed-pulsar") {
clusterEnabled = "true" clusterEnabled = "true"
} else if ("${MILVUS_SERVER_TYPE}" == "distributed-kafka") { } else if ("${MILVUS_SERVER_TYPE}" == "distributed-kafka") {
@ -114,6 +115,8 @@ pipeline {
// mysqlEnabled = "true" // mysqlEnabled = "true"
mqMode='kafka' mqMode='kafka'
// mysql_architecture = "replication" // mysql_architecture = "replication"
} else if("${MILVUS_SERVER_TYPE}" == "standalone-authentication") {
authenticationEnabled = "true"
} }
if ("${MILVUS_CLIENT}" == "pymilvus") { if ("${MILVUS_CLIENT}" == "pymilvus") {
if ("${imageTag}"==''){ if ("${imageTag}"==''){
@ -160,6 +163,7 @@ pipeline {
--set indexNode.disk.enabled=true \ --set indexNode.disk.enabled=true \
--set queryNode.disk.enabled=true \ --set queryNode.disk.enabled=true \
--set standalone.disk.enabled=true \ --set standalone.disk.enabled=true \
--set common.security.authorizationEnabled=${authenticationEnabled} \
--version ${chart_version} \ --version ${chart_version} \
-f values/${mqMode}.yaml \ -f values/${mqMode}.yaml \
-f values/mysql.yaml \ -f values/mysql.yaml \
@ -203,16 +207,30 @@ pipeline {
mqMode='kafka' mqMode='kafka'
tag="L0 L1 L2 ClusterOnly" tag="L0 L1 L2 ClusterOnly"
e2e_timeout_seconds = 6 * 60 * 60 e2e_timeout_seconds = 6 * 60 * 60
} else if("${MILVUS_SERVER_TYPE}" == "standalone-authentication") {
tag="L3"
e2e_timeout_seconds = 1 * 60 * 60
} }
if ("${MILVUS_CLIENT}" == "pymilvus") { if ("${MILVUS_CLIENT}" == "pymilvus") {
sh """ if ("${MILVUS_SERVER_TYPE}" == "standalone-authentication") {
MILVUS_HELM_RELEASE_NAME="${release_name}" \ sh """
MILVUS_HELM_NAMESPACE="milvus-ci" \ MILVUS_HELM_RELEASE_NAME="${release_name}" \
MILVUS_CLUSTER_ENABLED="${clusterEnabled}" \ MILVUS_HELM_NAMESPACE="milvus-ci" \
TEST_TIMEOUT="${e2e_timeout_seconds}" \ MILVUS_CLUSTER_ENABLED="${clusterEnabled}" \
MQ_MODE="${mqMode}" \ TEST_TIMEOUT="${e2e_timeout_seconds}" \
./ci_e2e.sh "-n 6 --tags ${tag}" MQ_MODE="${mqMode}" \
""" ./ci_e2e.sh "-n 4 --tags ${tag} testcases/test_utility.py::TestUtilityUserPassword testcases/test_utility.py::TestUtilityInvalidUserPassword"
"""
} else {
sh """
MILVUS_HELM_RELEASE_NAME="${release_name}" \
MILVUS_HELM_NAMESPACE="milvus-ci" \
MILVUS_CLUSTER_ENABLED="${clusterEnabled}" \
TEST_TIMEOUT="${e2e_timeout_seconds}" \
MQ_MODE="${mqMode}" \
./ci_e2e.sh "-n 6 --tags ${tag}"
"""
}
} else { } else {
error "Error: Unsupported Milvus client: ${MILVUS_CLIENT}" error "Error: Unsupported Milvus client: ${MILVUS_CLIENT}"
} }

1
tests/python_client/common/common_func.py
View File

@ -28,6 +28,7 @@ def ts_float32(val):
"""Used if *val* is an instance of numpy.float32.""" """Used if *val* is an instance of numpy.float32."""
return np.float64(val) return np.float64(val)
class ParamInfo: class ParamInfo:
def __init__(self): def __init__(self):
self.param_host = "" self.param_host = ""