Skip to content

Commit 092de33

Browse files
authored
Merge branch 'master' into ing-784-lookml-parameter
2 parents 6422b27 + 2e54461 commit 092de33

33 files changed

+2507
-1548
lines changed

metadata-ingestion/setup.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -741,7 +741,7 @@
741741
"hive-metastore = datahub.ingestion.source.sql.hive_metastore:HiveMetastoreSource",
742742
"json-schema = datahub.ingestion.source.schema.json_schema:JsonSchemaSource",
743743
"kafka = datahub.ingestion.source.kafka.kafka:KafkaSource",
744-
"kafka-connect = datahub.ingestion.source.kafka.kafka_connect:KafkaConnectSource",
744+
"kafka-connect = datahub.ingestion.source.kafka_connect.kafka_connect:KafkaConnectSource",
745745
"ldap = datahub.ingestion.source.ldap:LDAPSource",
746746
"looker = datahub.ingestion.source.looker.looker_source:LookerDashboardSource",
747747
"lookml = datahub.ingestion.source.looker.lookml_source:LookMLSource",

metadata-ingestion/src/datahub/configuration/source_common.py

+13
Original file line numberDiff line numberDiff line change
@@ -63,3 +63,16 @@ class DatasetLineageProviderConfigBase(EnvConfigMixin):
6363
default=None,
6464
description="A holder for platform -> platform_instance mappings to generate correct dataset urns",
6565
)
66+
67+
68+
class PlatformDetail(ConfigModel):
69+
platform_instance: Optional[str] = Field(
70+
default=None,
71+
description="DataHub platform instance name. To generate correct urn for upstream dataset, this should match "
72+
"with platform instance name used in ingestion "
73+
"recipe of other datahub sources.",
74+
)
75+
env: str = Field(
76+
default=DEFAULT_ENV,
77+
description="The environment that all assets produced by DataHub platform ingestion source belong to",
78+
)

0 commit comments

Comments
 (0)