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

Enable 70% of delta condition judgment for codecov (#7160)

Browse Source 
Signed-off-by: wangting0128 <ting.wang@zilliz.com>
This commit is contained in:
紫晴 2021-08-19 15:50:12 +08:00 committed by GitHub
parent ec9ccd8bd1
commit 7233b62dad
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.github/mergify.yml vendored
View File

@ -5,6 +5,7 @@ pull_request_rules:
- "status-success=Code Checker AMD64 Ubuntu 18.04" - "status-success=Code Checker AMD64 Ubuntu 18.04"
- "status-success=Build and test AMD64 Ubuntu 18.04" - "status-success=Build and test AMD64 Ubuntu 18.04"
- "status-success=continuous-integration/jenkins/pr-merge" - "status-success=continuous-integration/jenkins/pr-merge"
- "status-success=codecov/patch"
actions: actions:
label: label:
add: add:

5
codecov.yml
View File

@ -1,4 +1,8 @@
#Configuration File for CodeCov #Configuration File for CodeCov
codecov:
notify:
require_ci_to_pass: yes
coverage: coverage:
precision: 2 precision: 2
round: down round: down
@ -16,6 +20,7 @@ coverage:
threshold: 0% threshold: 0%
branches: branches:
- master - master
if_ci_failed: error #success, failure, error, ignore
comment: comment:
layout: "reach, diff, flags, files" layout: "reach, diff, flags, files"

2
internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
View File

@ -275,7 +275,6 @@ func (rmq *rocksmq) DestroyTopic(topicName string) error {
func (rmq *rocksmq) ExistConsumerGroup(topicName, groupName string) (bool, *Consumer) { func (rmq *rocksmq) ExistConsumerGroup(topicName, groupName string) (bool, *Consumer) {
key := groupName + "/" + topicName + "/current_id" key := groupName + "/" + topicName + "/current_id"
// keyExist := false // keyExist := false
// if ll, ok := topicMu.Load(topicName); !ok { // if ll, ok := topicMu.Load(topicName); !ok {
// keyExist = rmq.checkKeyExist(key) // keyExist = rmq.checkKeyExist(key)
@ -288,7 +287,6 @@ func (rmq *rocksmq) ExistConsumerGroup(topicName, groupName string) (bool, *Cons
// keyExist = rmq.checkKeyExist(key) // keyExist = rmq.checkKeyExist(key)
// } // }
// } // }
if rmq.checkKeyExist(key) { if rmq.checkKeyExist(key) {
if vals, ok := rmq.consumers.Load(topicName); ok { if vals, ok := rmq.consumers.Load(topicName); ok {
for _, v := range vals.([]*Consumer) { for _, v := range vals.([]*Consumer) {