diff --git a/pkg/storage/config/schema_config.go b/pkg/storage/config/schema_config.go index 370a26f28d..f035e79f06 100644 --- a/pkg/storage/config/schema_config.go +++ b/pkg/storage/config/schema_config.go @@ -430,7 +430,7 @@ func (cfg PeriodConfig) validate() error { } switch v { - case 10, 11, 12: + case 10, 11, 12, 13: if cfg.RowShards == 0 { return fmt.Errorf("must have row_shards > 0 (current: %d) for schema (%s)", cfg.RowShards, cfg.Schema) } diff --git a/pkg/storage/config/schema_config_test.go b/pkg/storage/config/schema_config_test.go index 9412c5b5f0..6d6cb78798 100644 --- a/pkg/storage/config/schema_config_test.go +++ b/pkg/storage/config/schema_config_test.go @@ -427,6 +427,15 @@ func TestPeriodConfig_Validate(t *testing.T) { ChunkTables: PeriodicTableConfig{Period: 0}, }, }, + { + desc: "v13", + in: PeriodConfig{ + Schema: "v13", + RowShards: 16, + IndexTables: PeriodicTableConfig{Period: 0}, + ChunkTables: PeriodicTableConfig{Period: 0}, + }, + }, } { t.Run(tc.desc, func(t *testing.T) { if tc.err == "" { @@ -555,6 +564,19 @@ func TestVersionAsInt(t *testing.T) { }, expected: int(12), }, + { + name: "v13", + schemaCfg: SchemaConfig{ + Configs: []PeriodConfig{ + { + From: DayTime{Time: 0}, + Schema: "v13", + RowShards: 16, + }, + }, + }, + expected: int(13), + }, } { t.Run(tc.name, func(t *testing.T) { version, err := tc.schemaCfg.Configs[0].VersionAsInt()