@@ -1119,7 +1119,7 @@ class InvalidQueryForExecutor(Exception):
1119
1119
1120
1120
class GroupAttributesPostgresSnubaQueryExecutor (PostgresSnubaQueryExecutor ):
1121
1121
def get_basic_group_snuba_condition (
1122
- self , search_filter : SearchFilter , joined_entitity : Entity
1122
+ self , search_filter : SearchFilter , joined_entity : Entity
1123
1123
) -> Condition :
1124
1124
"""
1125
1125
Returns the basic lookup for a search filter.
@@ -1131,22 +1131,22 @@ def get_basic_group_snuba_condition(
1131
1131
)
1132
1132
1133
1133
def get_basic_event_snuba_condition (
1134
- self , search_filter : SearchFilter , joined_entitity : Entity
1134
+ self , search_filter : SearchFilter , joined_entity : Entity
1135
1135
) -> Condition :
1136
1136
"""
1137
1137
Returns the basic lookup for a search filter.
1138
1138
"""
1139
1139
1140
- dataset = Dataset .Events if joined_entitity .alias == "e" else Dataset .IssuePlatform
1140
+ dataset = Dataset .Events if joined_entity .alias == "e" else Dataset .IssuePlatform
1141
1141
1142
1142
query_builder = UnresolvedQuery (
1143
1143
dataset = dataset ,
1144
- entity = joined_entitity ,
1144
+ entity = joined_entity ,
1145
1145
params = {},
1146
1146
)
1147
1147
return query_builder .default_filter_converter (search_filter )
1148
1148
1149
- def get_assigned (self , search_filter : SearchFilter , joined_entitity : Entity ) -> Condition :
1149
+ def get_assigned (self , search_filter : SearchFilter , joined_entity : Entity ) -> Condition :
1150
1150
"""
1151
1151
Returns the assigned lookup for a search filter.
1152
1152
"""
@@ -1182,7 +1182,7 @@ def get_assigned(self, search_filter: SearchFilter, joined_entitity: Entity) ->
1182
1182
1183
1183
return BooleanCondition (op = BooleanOp .OR , conditions = conditions )
1184
1184
1185
- def get_suggested (self , search_filter : SearchFilter , joined_entitity : Entity ) -> Condition :
1185
+ def get_suggested (self , search_filter : SearchFilter , joined_entity : Entity ) -> Condition :
1186
1186
"""
1187
1187
Returns the suggested lookup for a search filter.
1188
1188
"""
@@ -1253,13 +1253,13 @@ def get_suggested(self, search_filter: SearchFilter, joined_entitity: Entity) ->
1253
1253
)
1254
1254
1255
1255
def get_assigned_or_suggested (
1256
- self , search_filter : SearchFilter , joined_entitity : Entity
1256
+ self , search_filter : SearchFilter , joined_entity : Entity
1257
1257
) -> Condition :
1258
1258
return BooleanCondition (
1259
1259
op = BooleanOp .OR ,
1260
1260
conditions = [
1261
- self .get_assigned (search_filter , joined_entitity ),
1262
- self .get_suggested (search_filter , joined_entitity ),
1261
+ self .get_assigned (search_filter , joined_entity ),
1262
+ self .get_suggested (search_filter , joined_entity ),
1263
1263
],
1264
1264
)
1265
1265
@@ -1430,8 +1430,9 @@ def query(
1430
1430
orderby = [OrderBy (sort_func , direction = Direction .DESC )],
1431
1431
limit = Limit (limit + 1 ),
1432
1432
)
1433
+ dataset = Dataset .Events if joined_entity .alias == "e" else Dataset .IssuePlatform
1433
1434
request = Request (
1434
- dataset = "events" ,
1435
+ dataset = dataset ,
1435
1436
app_id = "group_attributes" ,
1436
1437
query = query ,
1437
1438
tenant_ids = tenant_ids ,
@@ -1447,7 +1448,7 @@ def query(
1447
1448
where = where_conditions ,
1448
1449
)
1449
1450
request = Request (
1450
- dataset = "events" ,
1451
+ dataset = dataset ,
1451
1452
app_id = "group_attributes" ,
1452
1453
query = hits_query ,
1453
1454
tenant_ids = tenant_ids ,
0 commit comments