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

address review comments

Browse Source
This commit is contained in:
Mahmood Ali
2018-11-20 13:21:39 -05:00
parent 10b073a81b
commit 72df87b101
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
nomad/state/state_store_test.go
View File

@@ -1667,29 +1667,34 @@ func TestStateStore_DeleteJobTxn_BatchDeletes(t *testing.T) {
const testJobCount = 10
const jobVersionCount = 4
stateIndex := uint64(1000)
jobs := make([]*structs.Job, testJobCount)
for i := 0; i < testJobCount; i++ {
stateIndex++
job := mock.BatchJob()
err := state.UpsertJob(uint64(100+i), job)
err := state.UpsertJob(stateIndex, job)
require.NoError(t, err)
jobs[i] = job
// create some versions
// Create some versions
for vi := 1; vi < jobVersionCount; vi++ {
stateIndex++
job := job.Copy()
job.TaskGroups[0].Tasks[0].Env = map[string]string{
"Version": fmt.Sprintf("%d", vi),
}
require.NoError(t, state.UpsertJob(uint64(100+i+vi*10), job))
require.NoError(t, state.UpsertJob(stateIndex, job))
}
}
ws := memdb.NewWatchSet()
// sanity check that jobs are present in DB
// Sanity check that jobs are present in DB
job, err := state.JobByID(ws, jobs[0].Namespace, jobs[0].ID)
require.NoError(t, err)
require.Equal(t, jobs[0].ID, job.ID)
@@ -1698,7 +1703,7 @@ func TestStateStore_DeleteJobTxn_BatchDeletes(t *testing.T) {
require.NoError(t, err)
require.Equal(t, jobVersionCount, len(jobVersions))
// actually delete
// Actually delete
const deletionIndex = uint64(10001)
err = state.WithWriteTransaction(func(txn Txn) error {
for i, job := range jobs {