|
@@ -13,16 +13,14 @@ from .metric_base import MetricBase
|
|
|
|
|
|
class MetricBySqlGeneral(MetricBase):
|
|
class MetricBySqlGeneral(MetricBase):
|
|
|
|
|
|
- def __init__(self, *args, data_loader: DataLoaderBase, sql: str, **kwargs):
|
|
|
|
- self._data_loader = data_loader
|
|
|
|
|
|
+ def __init__(self, sql: str, *args, **kwargs):
|
|
self._sql = sql
|
|
self._sql = sql
|
|
|
|
|
|
def validate_data(self):
|
|
def validate_data(self):
|
|
pass
|
|
pass
|
|
|
|
|
|
- def load_data(self, ) -> pd.DataFrame:
|
|
|
|
- return self._data_loader.get_data(self._sql)
|
|
|
|
-
|
|
|
|
- def calculate(self, ) -> MetricFucEntity:
|
|
|
|
- return MetricFucEntity(table=self.load_data())
|
|
|
|
|
|
+ def load_data(self, data_loader: DataLoaderBase) -> pd.DataFrame:
|
|
|
|
+ return data_loader.get_data(self._sql)
|
|
|
|
|
|
|
|
+ def calculate(self, data_loader: DataLoaderBase) -> MetricFucEntity:
|
|
|
|
+ return MetricFucEntity(table=self.load_data(data_loader))
|