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

fix: Remove timeout in datanode watch ctx (#35011) 

See also #35008

Use tickle timeout logic instead of hardcode context timeout

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/35015/head
congqixia 2024-07-25 22:17:45 +08:00 committed by GitHub
parent 63f0154dfb
commit e8038a76e1
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/datanode/channel/channel_manager.go
View File

@ -345,7 +345,7 @@ func (r *opRunner) watchWithTimer(info *datapb.ChannelWatchInfo) *opState {
) )
watchTimeout := paramtable.Get().DataCoordCfg.WatchTimeoutInterval.GetAsDuration(time.Second) watchTimeout := paramtable.Get().DataCoordCfg.WatchTimeoutInterval.GetAsDuration(time.Second)
ctx, cancel := context.WithTimeout(context.Background(), watchTimeout) ctx, cancel := context.WithCancel(context.Background())
defer cancel() defer cancel()
startTimer := func(finishWg *sync.WaitGroup) { startTimer := func(finishWg *sync.WaitGroup) {