Skip to content

Commit a258469

Browse files
committed
pr feedback
1 parent ed55059 commit a258469

File tree

2 files changed

+12
-8
lines changed

2 files changed

+12
-8
lines changed

metadata-ingestion/src/datahub/ingestion/source/looker/looker_usage.py

+9-8
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@
4242
TimeWindowSizeClass,
4343
_Aspect as AspectAbstract,
4444
)
45+
from datahub.utilities.lossy_collections import LossySet
4546

4647
logger = logging.getLogger(__name__)
4748

@@ -225,9 +226,8 @@ def get_id(self, looker_object: ModelForUsage) -> str:
225226
def get_id_from_row(self, row: dict) -> str:
226227
pass
227228

228-
@property
229229
@abstractmethod
230-
def SKIPPED_REPORT_KEY(self) -> str:
230+
def report_skip_set(self) -> LossySet[str]:
231231
pass
232232

233233
def create_mcp(
@@ -402,13 +402,10 @@ def generate_usage_stat_mcps(self) -> Iterable[MetadataChangeProposalWrapper]:
402402
if object_id in self.id_to_model:
403403
yield self.create_mcp(self.id_to_model[object_id], aspect)
404404
else:
405-
skipped_set = getattr(self.report, self.SKIPPED_REPORT_KEY)
406-
skipped_set.add(object_id)
405+
self.report_skip_set().add(object_id)
407406

408407

409408
class DashboardStatGenerator(BaseStatGenerator):
410-
SKIPPED_REPORT_KEY = "dashboards_skipped_for_usage"
411-
412409
def __init__(
413410
self,
414411
config: StatGeneratorConfig,
@@ -428,6 +425,9 @@ def __init__(
428425
def get_stats_generator_name(self) -> str:
429426
return "DashboardStats"
430427

428+
def report_skip_set(self) -> LossySet[str]:
429+
return self.report.dashboards_skipped_for_usage
430+
431431
def get_filter(self) -> Dict[ViewField, str]:
432432
return {
433433
HistoryViewField.HISTORY_DASHBOARD_ID: ",".join(
@@ -525,8 +525,6 @@ def append_user_stat(
525525

526526

527527
class LookStatGenerator(BaseStatGenerator):
528-
SKIPPED_REPORT_KEY = "charts_skipped_for_usage"
529-
530528
def __init__(
531529
self,
532530
config: StatGeneratorConfig,
@@ -546,6 +544,9 @@ def __init__(
546544
def get_stats_generator_name(self) -> str:
547545
return "ChartStats"
548546

547+
def report_skip_set(self) -> LossySet[str]:
548+
return self.report.charts_skipped_for_usage
549+
549550
def get_filter(self) -> Dict[ViewField, str]:
550551
return {
551552
LookViewField.LOOK_ID: ",".join(

metadata-ingestion/tests/integration/looker/looker_mces_usage_history.json

+3
Original file line numberDiff line numberDiff line change
@@ -581,7 +581,10 @@
581581
{
582582
"com.linkedin.pegasus2avro.dataset.DatasetProperties": {
583583
"customProperties": {
584+
"project": "lkml_samples",
585+
"model": "look_data",
584586
"looker.explore.label": "My Explore View",
587+
"looker.explore.name": "look_view",
585588
"looker.explore.file": "test_source_file.lkml"
586589
},
587590
"externalUrl": "https://looker.company.com/explore/look_data/look_view",

0 commit comments

Comments
 (0)