kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-01 16:05:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

e2e: account for race condition in periodic dispatch test.

Browse Source
This commit is contained in:
James Rasell
2021-02-11 11:08:48 +01:00
parent d8a7c6f3f2
commit 7cb48abb5a
2 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
e2e/periodic/input/simple.nomad
View File

@@ -25,4 +25,3 @@ job "periodic" {
}
}
}

17
e2e/periodic/periodic.go
View File

@@ -48,15 +48,24 @@ func (tc *PeriodicTest) TestPeriodicDispatch_Basic(f *framework.F) {
tc.jobIDs = append(tc.jobIDs, jobID)
// register job
e2eutil.Register(jobID, "periodic/input/simple.nomad")
require.NoError(t, e2eutil.Register(jobID, "periodic/input/simple.nomad"))
// force dispatch
require.NoError(t, e2eutil.PeriodicForce(jobID))
// Get the child job ID
childID, err := e2eutil.JobInspectTemplate(jobID, `{{with index . 1}}{{printf "%s" .ID}}{{end}}`)
require.NoError(t, err)
require.NotEmpty(t, childID)
testutil.WaitForResult(func() (bool, error) {
childID, err := e2eutil.JobInspectTemplate(jobID, `{{with index . 1}}{{printf "%s" .ID}}{{end}}`)
if err != nil {
return false, err
}
if childID != "" {
return true, nil
}
return false, fmt.Errorf("expected non-empty periodic child jobID for job %s", jobID)
}, func(err error) {
require.NoError(t, err)
})
testutil.WaitForResult(func() (bool, error) {
status, err := e2eutil.JobInspectTemplate(jobID, `{{with index . 1}}{{printf "%s" .Status}}{{end}}`)