Fix Profiler issue (#8796)

This commit is contained in:
Ayush Shah 2022-11-16 17:13:34 +05:30 committed by GitHub
parent 51559c590b
commit 44613b1532
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 4 additions and 5 deletions

View File

@ -48,6 +48,8 @@ base_requirements = {
"typing-compat~=0.1.0",
"importlib-metadata~=4.12.0", # From airflow constraints
"croniter~=1.3.0",
"requests-aws4auth==1.1.2",
"pymysql>=1.0.2",
}

View File

@ -180,7 +180,6 @@ class ElasticsearchSink(Sink[Entity]):
config: ElasticSearchConfig,
metadata_config: OpenMetadataConnection,
) -> None:
self.config = config
self.metadata_config = metadata_config

View File

@ -43,7 +43,7 @@ from metadata.orm_profiler.metrics.core import (
)
from metadata.orm_profiler.metrics.registry import Metrics
from metadata.orm_profiler.metrics.static.row_count import RowCount
from metadata.orm_profiler.orm.registry import NOT_COMPUTE, NOT_COMPUTE_OM
from metadata.orm_profiler.orm.registry import NOT_COMPUTE
from metadata.utils.logger import profiler_logger
logger = profiler_logger()
@ -311,9 +311,7 @@ class Profiler(Generic[TMetric]):
columns = [
column
for column in self.columns
if isinstance(column, Column)
and column.type.__class__ not in NOT_COMPUTE
or column.datatype not in NOT_COMPUTE_OM
if isinstance(column, Column) and column.type.__class__ not in NOT_COMPUTE
]
column_metrics_for_thread_pool = [