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

Fix tests

Browse Source
This commit is contained in:
Alex Dadgar
2016-01-07 13:32:45 -08:00
parent 4991d0098e
commit b4fd58a39a
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
nomad/periodic_test.go
View File

@@ -512,6 +512,15 @@ func TestPeriodicHeap_Order(t *testing.T) {
}
}
// deriveChildJob takes a parent periodic job and returns a job with fields set
// such that it appears spawned from the parent.
func deriveChildJob(parent *structs.Job) *structs.Job {
childjob := mock.Job()
childjob.ParentID = parent.ID
childjob.ID = fmt.Sprintf("%s%s%v", parent.ID, JobLaunchSuffix, time.Now().Unix())
return childjob
}
func TestPeriodicDispatch_RunningChildren_NoEvals(t *testing.T) {
s1 := testServer(t, nil)
defer s1.Shutdown()
@@ -546,8 +555,7 @@ func TestPeriodicDispatch_RunningChildren_ActiveEvals(t *testing.T) {
t.Fatalf("UpsertJob failed: %v", err)
}
childjob := mock.Job()
childjob.ParentID = job.ID
childjob := deriveChildJob(job)
if err := state.UpsertJob(1001, childjob); err != nil {
t.Fatalf("UpsertJob failed: %v", err)
}
@@ -582,8 +590,7 @@ func TestPeriodicDispatch_RunningChildren_ActiveAllocs(t *testing.T) {
t.Fatalf("UpsertJob failed: %v", err)
}
childjob := mock.Job()
childjob.ParentID = job.ID
childjob := deriveChildJob(job)
if err := state.UpsertJob(1001, childjob); err != nil {
t.Fatalf("UpsertJob failed: %v", err)
}