@@ -232,7 +232,10 @@ def query_replays_dataset_tagkey_values(
232
232
if tag_substr_query :
233
233
where .append (
234
234
Condition (
235
- Function ("positionCaseInsensitive" , parameters = [grouped_column , tag_substr_query ]),
235
+ Function (
236
+ "positionCaseInsensitive" ,
237
+ parameters = [grouped_column , tag_substr_query ],
238
+ ),
236
239
Op .NEQ ,
237
240
0 ,
238
241
)
@@ -269,7 +272,9 @@ def query_replays_dataset_tagkey_values(
269
272
tenant_ids = tenant_ids ,
270
273
)
271
274
return raw_snql_query (
272
- snuba_request , referrer = "replays.query.query_replays_dataset_tagkey_values" , use_cache = True
275
+ snuba_request ,
276
+ referrer = "replays.query.query_replays_dataset_tagkey_values" ,
277
+ use_cache = True ,
273
278
)
274
279
275
280
@@ -280,7 +285,10 @@ def anyIfNonZeroIP(
280
285
) -> Function :
281
286
return Function (
282
287
"anyIf" ,
283
- parameters = [Column (column_name ), Function ("greater" , parameters = [Column (column_name ), 0 ])],
288
+ parameters = [
289
+ Column (column_name ),
290
+ Function ("greater" , parameters = [Column (column_name ), 0 ]),
291
+ ],
284
292
alias = alias or column_name if aliased else None ,
285
293
)
286
294
@@ -305,7 +313,8 @@ def _sorted_aggregated_urls(agg_urls_column, alias):
305
313
"arrayMap" ,
306
314
parameters = [
307
315
Lambda (
308
- ["url_tuple" ], Function ("tupleElement" , parameters = [Identifier ("url_tuple" ), 2 ])
316
+ ["url_tuple" ],
317
+ Function ("tupleElement" , parameters = [Identifier ("url_tuple" ), 2 ]),
309
318
),
310
319
agg_urls_column ,
311
320
],
@@ -314,7 +323,8 @@ def _sorted_aggregated_urls(agg_urls_column, alias):
314
323
"arrayMap" ,
315
324
parameters = [
316
325
Lambda (
317
- ["url_tuple" ], Function ("tupleElement" , parameters = [Identifier ("url_tuple" ), 1 ])
326
+ ["url_tuple" ],
327
+ Function ("tupleElement" , parameters = [Identifier ("url_tuple" ), 1 ]),
318
328
),
319
329
agg_urls_column ,
320
330
],
@@ -450,7 +460,11 @@ def _collect_event_ids(alias, ids_type_list):
450
460
parameters = [
451
461
Lambda (
452
462
["error_id_no_dashes" ],
453
- _strip_uuid_dashes ("error_id_no_dashes" , Identifier ("error_id_no_dashes" )),
463
+ _strip_uuid_dashes (
464
+ "error_id_no_dashes" ,
465
+ Identifier ("error_id_no_dashes" ),
466
+ aliased = False ,
467
+ ),
454
468
),
455
469
Function ("flatten" , [id_types_to_aggregate ]),
456
470
],
@@ -558,7 +572,11 @@ def _empty_uuids_lambda():
558
572
"browser" : ["browser_name" , "browser_version" ],
559
573
"device" : ["device_name" , "device_brand" , "device_family" , "device_model" ],
560
574
"sdk" : ["sdk_name" , "sdk_version" ],
561
- "ota_updates" : ["ota_updates_channel" , "ota_updates_runtime_version" , "ota_updates_update_id" ],
575
+ "ota_updates" : [
576
+ "ota_updates_channel" ,
577
+ "ota_updates_runtime_version" ,
578
+ "ota_updates_update_id" ,
579
+ ],
562
580
"tags" : ["tk" , "tv" ],
563
581
# Nested fields. Useful for selecting searchable fields.
564
582
"user.id" : ["user_id" ],
@@ -634,7 +652,10 @@ def _empty_uuids_lambda():
634
652
"replay_id" : Column ("replay_id" ),
635
653
"agg_project_id" : Function (
636
654
"anyIf" ,
637
- parameters = [Column ("project_id" ), Function ("equals" , parameters = [Column ("segment_id" ), 0 ])],
655
+ parameters = [
656
+ Column ("project_id" ),
657
+ Function ("equals" , parameters = [Column ("segment_id" ), 0 ]),
658
+ ],
638
659
alias = "agg_project_id" ,
639
660
),
640
661
"trace_ids" : Function (
@@ -762,7 +783,9 @@ def _empty_uuids_lambda():
762
783
"click.text" : Function ("groupArray" , parameters = [Column ("click_text" )], alias = "click_text" ),
763
784
"click.title" : Function ("groupArray" , parameters = [Column ("click_title" )], alias = "click_title" ),
764
785
"click.component_name" : Function (
765
- "groupArray" , parameters = [Column ("click_component_name" )], alias = "click_component_name"
786
+ "groupArray" ,
787
+ parameters = [Column ("click_component_name" )],
788
+ alias = "click_component_name" ,
766
789
),
767
790
"error_ids" : _collect_new_errors (),
768
791
"warning_ids" : _collect_event_ids ("warning_ids" , ["warning_id" ]),
0 commit comments