Skip to content
106 changes: 0 additions & 106 deletions snuba/datasets/cdc/groupassignee_processor.py

This file was deleted.

12 changes: 0 additions & 12 deletions snuba/datasets/cdc/row_processors.py
Original file line number Diff line number Diff line change
@@ -1,8 +1,6 @@
from abc import ABC, abstractmethod
from typing import Type, cast

from snuba.datasets.cdc.groupassignee_processor import GroupAssigneeRow
from snuba.datasets.cdc.groupedmessage_processor import GroupedMessageRow
from snuba.snapshots import SnapshotTableRow
from snuba.utils.registered_class import RegisteredClass
from snuba.writer import WriterTableRow
Expand All @@ -24,13 +22,3 @@ def get_from_name(cls, name: str) -> Type["CdcRowProcessor"]:
@classmethod
def config_key(cls) -> str:
return cls.__name__


class GroupAssigneeRowProcessor(CdcRowProcessor):
def process(self, row: SnapshotTableRow) -> WriterTableRow:
return GroupAssigneeRow.from_bulk(row).to_clickhouse()


class GroupedMessageRowProcessor(CdcRowProcessor):
def process(self, row: SnapshotTableRow) -> WriterTableRow:
return GroupedMessageRow.from_bulk(row).to_clickhouse()
Original file line number Diff line number Diff line change
Expand Up @@ -544,16 +544,4 @@ subscription_validators:
- orderby
required_time_column: timestamp

join_relationships:
grouped:
rhs_entity: groupedmessage
join_type: inner
columns:
- [project_id, project_id]
- [group_id, id]
assigned:
rhs_entity: groupassignee
join_type: inner
columns:
- [project_id, project_id]
- [group_id, group_id]
join_relationships: {}
12 changes: 0 additions & 12 deletions snuba/datasets/configuration/events/entities/events.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -541,18 +541,6 @@ subscription_validators:
allows_group_by_without_condition: true

join_relationships:
grouped:
rhs_entity: groupedmessage
join_type: inner
columns:
- [project_id, project_id]
- [group_id, id]
assigned:
rhs_entity: groupassignee
join_type: inner
columns:
- [project_id, project_id]
- [group_id, group_id]
attributes:
rhs_entity: group_attributes
join_type: left
Expand Down
6 changes: 0 additions & 6 deletions snuba/datasets/configuration/groupassignee/dataset.yaml

This file was deleted.

This file was deleted.

This file was deleted.

6 changes: 0 additions & 6 deletions snuba/datasets/configuration/groupedmessage/dataset.yaml

This file was deleted.

This file was deleted.

Loading
Loading