func TestOneTime_RunJobAt_RunTwice(t *testing.T) { t.Parallel() store, cleanup := cltest.NewStore() defer cleanup() ot := services.OneTime{ Clock: store.Clock, Store: store, } j, initr := cltest.NewJobWithRunAtInitiator(time.Now()) assert.Nil(t, store.SaveJob(&j)) ot.RunJobAt(initr, j) initr.Time = models.Time{Time: time.Now().Add(time.Second * 2)} ot.RunJobAt(initr, j) jobRuns := []models.JobRun{} assert.Nil(t, store.Where("JobID", j.ID, &jobRuns)) assert.Equal(t, 1, len(jobRuns)) }