Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix(cdc): remove cdc stuff for real #6806

Open
wants to merge 6 commits into
base: master
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
110 changes: 0 additions & 110 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()
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.

This file was deleted.

1 change: 0 additions & 1 deletion snuba/settings/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,6 @@
"ca_certs": os.environ.get("CLICKHOUSE_CA_CERTS"),
"verify": os.environ.get("CLICKHOUSE_VERIFY"),
"storage_sets": {
"cdc",
"discover",
"events",
"events_ro",
Expand Down
Loading
Loading