yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-08-20 06:58:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix metadata es DAG (#5933)

Browse Source
This commit is contained in:
Pere Miquel Brull 2022-07-07 21:15:09 +02:00 committed by GitHub
parent 27467a618a
commit a6dd100be4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ingestion/examples/airflow/dags/airflow_metadata_to_es.py
View File

@ -49,7 +49,7 @@ config = """
"sourceConfig":{"config":{}} "sourceConfig":{"config":{}}
}, },
"sink": { "sink": {
"type": "elasticsearch_mapping", "type": "elasticsearch",
"config": { "config": {
"index_tables": "true", "index_tables": "true",
"index_topics": "true", "index_topics": "true",

1
ingestion/src/metadata/ingestion/sink/elasticsearch.py
View File

@ -35,7 +35,6 @@ from metadata.generated.schema.entity.services.connections.metadata.openMetadata
from metadata.generated.schema.entity.tags.tagCategory import TagCategory from metadata.generated.schema.entity.tags.tagCategory import TagCategory
from metadata.generated.schema.entity.teams.team import Team from metadata.generated.schema.entity.teams.team import Team
from metadata.generated.schema.entity.teams.user import User from metadata.generated.schema.entity.teams.user import User
from metadata.generated.schema.type import entityReference
from metadata.generated.schema.type.entityReference import EntityReference from metadata.generated.schema.type.entityReference import EntityReference
from metadata.ingestion.api.common import Entity from metadata.ingestion.api.common import Entity
from metadata.ingestion.api.sink import Sink, SinkStatus from metadata.ingestion.api.sink import Sink, SinkStatus