Skip to content

Commit 9472f0e

Browse files
ulixius9claudeKhairajani
committed
fix(ingestion): register Drive entities in ENTITY_REFERENCE_CLASS_MAP and ES_INDEX_MAP (#28104)
* fix(ingestion): add Drive entities to ENTITY_REFERENCE_CLASS_MAP The Automator app resolves resource types from resources.type against ENTITY_REFERENCE_CLASS_MAP. Drive entities (directory, file, spreadsheet, worksheet) and the driveService were missing, so selecting them in the Add Automation UI failed at runtime with: AutomatorException: Can't get class from resource type: directory Register the Drive data entities and driveService so the Automator can paginate and act on them. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com> * Adding missng drive entity to ES MAP --------- Co-authored-by: Claude Opus 4.7 (1M context) <noreply@anthropic.com> Co-authored-by: Khairajani <himanshukhairajani8@gmail.com> Co-authored-by: Himanshu Khairajani <46777429+Khairajani@users.noreply.github.com>
1 parent 1be216c commit 9472f0e

2 files changed

Lines changed: 19 additions & 0 deletions

File tree

ingestion/src/metadata/utils/constants.py

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,15 +20,19 @@
2020
from metadata.generated.schema.entity.data.dashboardDataModel import DashboardDataModel
2121
from metadata.generated.schema.entity.data.database import Database
2222
from metadata.generated.schema.entity.data.databaseSchema import DatabaseSchema
23+
from metadata.generated.schema.entity.data.directory import Directory
24+
from metadata.generated.schema.entity.data.file import File
2325
from metadata.generated.schema.entity.data.glossary import Glossary
2426
from metadata.generated.schema.entity.data.glossaryTerm import GlossaryTerm
2527
from metadata.generated.schema.entity.data.metric import Metric
2628
from metadata.generated.schema.entity.data.mlmodel import MlModel
2729
from metadata.generated.schema.entity.data.pipeline import Pipeline
2830
from metadata.generated.schema.entity.data.searchIndex import SearchIndex
31+
from metadata.generated.schema.entity.data.spreadsheet import Spreadsheet
2932
from metadata.generated.schema.entity.data.storedProcedure import StoredProcedure
3033
from metadata.generated.schema.entity.data.table import Table
3134
from metadata.generated.schema.entity.data.topic import Topic
35+
from metadata.generated.schema.entity.data.worksheet import Worksheet
3236
from metadata.generated.schema.entity.domains.dataProduct import DataProduct
3337
from metadata.generated.schema.entity.domains.domain import Domain
3438
from metadata.generated.schema.entity.services.apiService import ApiService
@@ -67,6 +71,7 @@
6771
)
6872
from metadata.generated.schema.entity.services.dashboardService import DashboardService
6973
from metadata.generated.schema.entity.services.databaseService import DatabaseService
74+
from metadata.generated.schema.entity.services.driveService import DriveService
7075
from metadata.generated.schema.entity.services.messagingService import MessagingService
7176
from metadata.generated.schema.entity.services.metadataService import MetadataService
7277
from metadata.generated.schema.entity.services.mlmodelService import MlModelService
@@ -131,6 +136,7 @@
131136
"metadataService": MetadataService,
132137
"searchService": SearchService,
133138
"securityService": SecurityService,
139+
"driveService": DriveService,
134140
# Data Asset Entities
135141
"apiCollection": APICollection,
136142
"apiEndpoint": APIEndpoint,
@@ -146,6 +152,11 @@
146152
"searchIndex": SearchIndex,
147153
"mlmodel": MlModel,
148154
"container": Container,
155+
# Drive Entities
156+
"directory": Directory,
157+
"file": File,
158+
"spreadsheet": Spreadsheet,
159+
"worksheet": Worksheet,
149160
# User Entities
150161
"user": User,
151162
"team": Team,

ingestion/src/metadata/utils/elasticsearch.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,16 +29,20 @@
2929
from metadata.generated.schema.entity.data.dashboardDataModel import DashboardDataModel
3030
from metadata.generated.schema.entity.data.database import Database
3131
from metadata.generated.schema.entity.data.databaseSchema import DatabaseSchema
32+
from metadata.generated.schema.entity.data.directory import Directory
33+
from metadata.generated.schema.entity.data.file import File
3234
from metadata.generated.schema.entity.data.glossary import Glossary
3335
from metadata.generated.schema.entity.data.glossaryTerm import GlossaryTerm
3436
from metadata.generated.schema.entity.data.metric import Metric
3537
from metadata.generated.schema.entity.data.mlmodel import MlModel
3638
from metadata.generated.schema.entity.data.pipeline import Pipeline
3739
from metadata.generated.schema.entity.data.query import Query
3840
from metadata.generated.schema.entity.data.searchIndex import SearchIndex
41+
from metadata.generated.schema.entity.data.spreadsheet import Spreadsheet
3942
from metadata.generated.schema.entity.data.storedProcedure import StoredProcedure
4043
from metadata.generated.schema.entity.data.table import Table
4144
from metadata.generated.schema.entity.data.topic import Topic
45+
from metadata.generated.schema.entity.data.worksheet import Worksheet
4246
from metadata.generated.schema.entity.services.apiService import ApiService
4347
from metadata.generated.schema.entity.services.databaseService import DatabaseService
4448
from metadata.generated.schema.entity.teams.team import Team
@@ -71,6 +75,10 @@
7175
Tag.__name__: "tag_search_index",
7276
Classification.__name__: "classification_search_index",
7377
Container.__name__: "container_search_index",
78+
Directory.__name__: "directory_search_index",
79+
File.__name__: "file_search_index",
80+
Spreadsheet.__name__: "spreadsheet_search_index",
81+
Worksheet.__name__: "worksheet_search_index",
7482
Query.__name__: "query_search_index",
7583
ReportData.__name__: "entity_report_data_index",
7684
Metric.__name__: "metric_search_index",

0 commit comments

Comments
 (0)