Skip to content

Commit

Permalink
increase tome to 5s
Browse files Browse the repository at this point in the history
  • Loading branch information
sakoush committed Nov 1, 2024
1 parent ddae74f commit 019610d
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion scheduler/pkg/agent/server_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -1062,7 +1062,7 @@ func TestSubscribe(t *testing.T) {
}(idx, s)
}

time.Sleep(1500 * time.Millisecond)
time.Sleep(5000 * time.Millisecond)

g.Expect(len(server.agents)).To(Equal(test.expectedAgentsCountAfterClose))

Expand Down
2 changes: 1 addition & 1 deletion scheduler/pkg/kafka/dataflow/server_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -749,7 +749,7 @@ func TestPipelineSubscribe(t *testing.T) {
}(idx, s)
}

time.Sleep(1500 * time.Millisecond)
time.Sleep(5000 * time.Millisecond)

g.Expect(len(s.streams)).To(Equal(test.expectedAgentsCountAfterClose))

Expand Down

0 comments on commit 019610d

Please sign in to comment.