diff --git a/database-3_test.go b/database-3_test.go index b46304d8794e7ecb890c6e8dc461dedf5b81b677..cdf2df96b221ec543d9a89643a5213c8b7ea4f2f 100644 --- a/database-3_test.go +++ b/database-3_test.go @@ -19,6 +19,8 @@ func TestWriteToDB3(t *testing.T) { t.Fatalf("a error occurred while opening the database: %v", err) } + db.Logger = db.Logger.LogMode(4) + manager := NewManager() manager.SetDB(db) err = manager.AddWorker(NewLocalWorker(1)) @@ -35,6 +37,15 @@ func TestWriteToDB3(t *testing.T) { time.Sleep(1 * time.Second) + // test is job in database + var tmpJob1 JobPersistence + r := db.First(&tmpJob1, "id = ?", "job2") + + assert.Nil(t, r.Error) + assert.Equal(t, JobID("job2"), tmpJob1.ID) + + time.Sleep(1 * time.Second) + err = manager.DeleteJob(job.GetID()) assert.Nil(t, err) diff --git a/database-5_test.go b/database-5_test.go index febe77c1b7496c0e013b4fd56e21f795737ec5d9..bdd667a8417dcec7c747701d292b372cbf22d98f 100644 --- a/database-5_test.go +++ b/database-5_test.go @@ -7,6 +7,7 @@ import ( "gorm.io/driver/sqlite" "gorm.io/gorm" "testing" + "time" ) func TestWriteToDB5(t *testing.T) { @@ -35,6 +36,8 @@ func TestWriteToDB5(t *testing.T) { sameIDJob := NewJob[CounterResult]("jobSameID", runner) + time.Sleep(500 * time.Millisecond) + // Trying to save a job with the same ID should do nothing mgr.mu.Lock() mgr.jobSyncer.AddJob(sameIDJob) diff --git a/manager.go b/manager.go index 70307a30564383328c3ce23bf6b38881aae74152..848458bf51fc22c954b4a6464e1e0c6fa6733897 100644 --- a/manager.go +++ b/manager.go @@ -389,7 +389,6 @@ func (m *Manager) RemoveWorker(worker Worker) error { // Start starts the manager func (m *Manager) Start() error { - //var err error m.mu.Lock() defer m.mu.Unlock()