Skip to content

Commit

Permalink
chore(dao): Remove redundant convenience methods (apache#24967)
Browse files Browse the repository at this point in the history
  • Loading branch information
john-bodley authored Aug 14, 2023
1 parent 6cf17dc commit d9ba000
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 56 deletions.
52 changes: 0 additions & 52 deletions superset/daos/dataset.py
Original file line number Diff line number Diff line change
Expand Up @@ -301,31 +301,6 @@ def find_dataset_column(cls, dataset_id: int, column_id: int) -> TableColumn | N
.one_or_none()
)

@classmethod
def update_column(
cls,
model: TableColumn,
properties: dict[str, Any],
commit: bool = True,
) -> TableColumn:
return DatasetColumnDAO.update(model, properties, commit=commit)

@classmethod
def create_column(
cls, properties: dict[str, Any], commit: bool = True
) -> TableColumn:
"""
Creates a Dataset model on the metadata DB
"""
return DatasetColumnDAO.create(attributes=properties, commit=commit)

@classmethod
def delete_column(cls, model: TableColumn, commit: bool = True) -> None:
"""
Deletes a Dataset column
"""
DatasetColumnDAO.delete(model, commit=commit)

@classmethod
def find_dataset_metric(cls, dataset_id: int, metric_id: int) -> SqlMetric | None:
# We want to apply base dataset filters
Expand All @@ -334,33 +309,6 @@ def find_dataset_metric(cls, dataset_id: int, metric_id: int) -> SqlMetric | Non
return None
return db.session.query(SqlMetric).get(metric_id)

@classmethod
def delete_metric(cls, model: SqlMetric, commit: bool = True) -> None:
"""
Deletes a Dataset metric
"""
DatasetMetricDAO.delete(model, commit=commit)

@classmethod
def update_metric(
cls,
model: SqlMetric,
properties: dict[str, Any],
commit: bool = True,
) -> SqlMetric:
return DatasetMetricDAO.update(model, properties, commit=commit)

@classmethod
def create_metric(
cls,
properties: dict[str, Any],
commit: bool = True,
) -> SqlMetric:
"""
Creates a Dataset model on the metadata DB
"""
return DatasetMetricDAO.create(attributes=properties, commit=commit)

@classmethod
def delete(
cls,
Expand Down
4 changes: 2 additions & 2 deletions superset/datasets/columns/commands/delete.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
from superset import security_manager
from superset.commands.base import BaseCommand
from superset.connectors.sqla.models import TableColumn
from superset.daos.dataset import DatasetDAO
from superset.daos.dataset import DatasetColumnDAO, DatasetDAO
from superset.daos.exceptions import DAODeleteFailedError
from superset.datasets.columns.commands.exceptions import (
DatasetColumnDeleteFailedError,
Expand All @@ -43,7 +43,7 @@ def run(self) -> None:
assert self._model

try:
DatasetDAO.delete_column(self._model)
DatasetColumnDAO.delete(self._model)
except DAODeleteFailedError as ex:
logger.exception(ex.exception)
raise DatasetColumnDeleteFailedError() from ex
Expand Down
4 changes: 2 additions & 2 deletions superset/datasets/metrics/commands/delete.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
from superset import security_manager
from superset.commands.base import BaseCommand
from superset.connectors.sqla.models import SqlMetric
from superset.daos.dataset import DatasetDAO
from superset.daos.dataset import DatasetDAO, DatasetMetricDAO
from superset.daos.exceptions import DAODeleteFailedError
from superset.datasets.metrics.commands.exceptions import (
DatasetMetricDeleteFailedError,
Expand All @@ -43,7 +43,7 @@ def run(self) -> None:
assert self._model

try:
DatasetDAO.delete_metric(self._model)
DatasetMetricDAO.delete(self._model)
except DAODeleteFailedError as ex:
logger.exception(ex.exception)
raise DatasetMetricDeleteFailedError() from ex
Expand Down

0 comments on commit d9ba000

Please sign in to comment.