mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
Merge pull request #27296 from tonistiigi/wait-tasks
Wait until tasks have been created in TestSwarmTaskListFilter
This commit is contained in:
commit
535f52c932
1 changed files with 11 additions and 0 deletions
|
@ -287,6 +287,15 @@ func (s *DockerSwarmSuite) TestSwarmTaskListFilter(c *check.C) {
|
|||
|
||||
filter := "name=redis-cluster"
|
||||
|
||||
checkNumTasks := func(*check.C) (interface{}, check.CommentInterface) {
|
||||
out, err := d.Cmd("service", "ps", "--filter", filter, name)
|
||||
c.Assert(err, checker.IsNil)
|
||||
return len(strings.Split(out, "\n")) - 2, nil // includes header and nl in last line
|
||||
}
|
||||
|
||||
// wait until all tasks have been created
|
||||
waitAndAssert(c, defaultReconciliationTimeout, checkNumTasks, checker.Equals, 3)
|
||||
|
||||
out, err = d.Cmd("service", "ps", "--filter", filter, name)
|
||||
c.Assert(err, checker.IsNil)
|
||||
c.Assert(out, checker.Contains, name+".1")
|
||||
|
@ -310,6 +319,8 @@ func (s *DockerSwarmSuite) TestSwarmTaskListFilter(c *check.C) {
|
|||
c.Assert(err, checker.IsNil)
|
||||
c.Assert(strings.TrimSpace(out), checker.Not(checker.Equals), "")
|
||||
|
||||
waitAndAssert(c, defaultReconciliationTimeout, checkNumTasks, checker.Equals, 1)
|
||||
|
||||
filter = "name=redis-cluster"
|
||||
out, err = d.Cmd("service", "ps", "--filter", filter, name)
|
||||
c.Assert(err, checker.IsNil)
|
||||
|
|
Loading…
Add table
Reference in a new issue