Skip to content

Commit

Permalink
Fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
scudette committed Jan 28, 2025
1 parent 229dd83 commit 39da440
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 1 deletion.
5 changes: 5 additions & 0 deletions services/client_info/client_info.go
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,11 @@ func (self *ClientInfoManager) ListClients(ctx context.Context) <-chan string {
defer close(output_chan)

for _, key := range self.storage.Keys() {
// Ignore the server - it is not a real client.
if key == "server" {
continue
}

select {
case <-ctx.Done():
return
Expand Down
2 changes: 1 addition & 1 deletion services/launcher/launcher_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -1381,7 +1381,7 @@ func (self *LauncherTestSuite) TestDelete() {
// However GetFlows omits the deleted flow immediately because it
// can not find it (The actual flow object is removed but the
// index is out of step).
vtesting.WaitUntil(5*time.Second, self.T(), func() bool {
vtesting.WaitUntil(10*time.Second, self.T(), func() bool {
res, err = launcher.GetFlows(self.Ctx, self.ConfigObj, "server",
result_sets.ResultSetOptions{}, 0, 10)
assert.NoError(self.T(), err)
Expand Down

0 comments on commit 39da440

Please sign in to comment.