mirror of https://github.com/milvus-io/milvus.git
parent
0695c88844
commit
86ed2fd51f
|
@ -173,10 +173,6 @@ func (s *ChannelManagerSuite) TestSubmitWatchAndRelease() {
|
|||
err = s.manager.Submit(info)
|
||||
s.NoError(err)
|
||||
|
||||
resp = s.manager.GetProgress(info)
|
||||
s.Equal(info.GetOpID(), resp.GetOpID())
|
||||
s.Equal(datapb.ChannelWatchState_ToRelease, resp.GetState())
|
||||
|
||||
opState = <-s.manager.communicateCh
|
||||
s.NotNil(opState)
|
||||
s.Equal(datapb.ChannelWatchState_ReleaseSuccess, opState.state)
|
||||
|
|
Loading…
Reference in New Issue