fixup! chore: plugging in jobsdb.NewDistinctValuesCache

Author: Sidddddarth

app/cluster/integration_test.go

@@ -107,8 +107,6 @@ func TestDynamicClusterManager(t *testing.T) {
 	defer gwDB.TearDown()
 	eschDB := jobsdb.NewForReadWrite("esch", jobsdb.WithStats(stats.NOP))
 	defer eschDB.TearDown()
-	archiveDB := jobsdb.NewForReadWrite("archive", jobsdb.WithStats(stats.NOP))
-	defer archiveDB.TearDown()
 	rtDB := jobsdb.NewForReadWrite("rt", jobsdb.WithStats(stats.NOP))
 	defer rtDB.TearDown()
 	brtDB := jobsdb.NewForReadWrite("batch_rt", jobsdb.WithStats(stats.NOP))
@@ -199,7 +197,7 @@ func TestDynamicClusterManager(t *testing.T) {
 		ArchivalDB:      archDB,
 		SchemaForwarder: schemaForwarder,
 		Archiver: arc.New(
-			archiveDB,
+			archDB,
 			nil,
 			config.Default,
 			stats.Default,

jobsdb/jobsdb.go

@@ -1959,10 +1959,6 @@ func (jd *Handle) getDistinctValuesPerDataset(
 	dsList []string,
 	param ParameterName,
 ) (map[string][]string, error) {
-	if len(dsList) == 0 {
-		return nil, nil
-	}
-
 	var queries []string
 	for _, ds := range dsList {
 		queries = append(queries, fmt.Sprintf(parametersWithoutCustomval, param.string(), ds))
@@ -2001,6 +1997,7 @@ func (jd *Handle) GetDistinctParameterValues(ctx context.Context, parameter Para
 			return nil, fmt.Errorf("could not acquire a dslist read lock: %w", ctx.Err())
 		}
 		dsList := jd.getDSList()
+		jd.logger.Info(dsList)
 		jd.dsListLock.RUnlock()
 		values, err := jd.distinctValuesCache.GetDistinctValues(
 			parameter.string(),