cleanup

Co-authored-by: Aris Tzoumas <atzoumas@rudderstack.com>
rudderlabs · Oct 14, 2022 · 772d97c · 772d97c
1 parent 90277cf
commit 772d97c
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/jobsdb/integration_test.go b/jobsdb/integration_test.go
@@ -732,22 +732,16 @@ func TestJobsDB(t *testing.T) {
 		require.EqualValues(t, 2, len(jobDBInspector.DSIndicesList()))
 		require.EqualValues(t, 2, jobDB.GetMaxDSIndex())
 
-		// time.Sleep(time.Second * 2)   // wait for some time to pass
-		// triggerAddNewDS <- time.Now() // trigger addNewDSLoop to run
-		// triggerAddNewDS <- time.Now() // Second time, waits for the first loop to finish
-
-		// require.EqualValues(t, 3, len(jobDBInspector.DSIndicesList()))
-		// require.EqualValues(t, 3, jobDB.GetMaxDSIndex())
 
 		time.Sleep(time.Second * 2) // wait for some time to pass so that retention condition satisfies
 
 		triggerMigrateDS <- time.Now() // trigger migrateDSLoop to run
 		triggerMigrateDS <- time.Now() // Second time, waits for the first loop to finish
 
 		dsIndicesList := jobDBInspector.DSIndicesList()
+		require.EqualValues(t, 2, len(jobDBInspector.DSIndicesList()))
 		require.EqualValues(t, "1_1", dsIndicesList[0])
 		require.EqualValues(t, "2", dsIndicesList[1])
-		require.EqualValues(t, 2, len(jobDBInspector.DSIndicesList()))
 		require.EqualValues(t, 2, jobDB.GetMaxDSIndex())
 
 		// only non-terminal jobs should be migrated