diff --git a/snuba/snuba_migrations/events_analytics_platform/0001_spans_v2.py b/snuba/snuba_migrations/events_analytics_platform/0001_spans.py similarity index 95% rename from snuba/snuba_migrations/events_analytics_platform/0001_spans_v2.py rename to snuba/snuba_migrations/events_analytics_platform/0001_spans.py index 2d5c4c41ba1..899aff4dace 100644 --- a/snuba/snuba_migrations/events_analytics_platform/0001_spans_v2.py +++ b/snuba/snuba_migrations/events_analytics_platform/0001_spans.py @@ -20,6 +20,7 @@ storage_set_name = StorageSetKey.EVENTS_ANALYTICS_PLATFORM local_table_name = "eap_spans_local" dist_table_name = "eap_spans_dist" +num_attr_buckets = 200 columns: List[Column[Modifiers]] = [ Column("organization_id", UInt(64)), @@ -59,7 +60,7 @@ f"attr_str_{i}", Map(String(), String(), modifiers=Modifiers(codecs=["ZSTD(1)"])), ) - for i in range(50) + for i in range(num_attr_buckets) ] ) @@ -69,7 +70,7 @@ f"attr_num_{i}", Map(String(), Float(64), modifiers=Modifiers(codecs=["ZSTD(1)"])), ) - for i in range(50) + for i in range(num_attr_buckets) ] ) columns.extend( @@ -78,7 +79,7 @@ f"attr_bool_{i}", Map(String(), Bool(), modifiers=Modifiers(codecs=["ZSTD(1)"])), ) - for i in range(50) + for i in range(num_attr_buckets) ] ) @@ -104,7 +105,7 @@ granularity=1, target=OperationTarget.LOCAL, ) - for i in range(50) + for i in range(num_attr_buckets) ] + [ operations.AddIndex( @@ -116,7 +117,7 @@ granularity=1, target=OperationTarget.LOCAL, ) - for i in range(50) + for i in range(num_attr_buckets) ] + [ operations.AddIndex( @@ -128,7 +129,7 @@ granularity=1, target=OperationTarget.LOCAL, ) - for i in range(50) + for i in range(num_attr_buckets) ] + [ operations.AddIndex( @@ -140,7 +141,7 @@ granularity=1, target=OperationTarget.LOCAL, ) - for i in range(50) + for i in range(num_attr_buckets) ] )