mirror of
https://github.com/open-metadata/OpenMetadata.git
synced 2025-08-07 08:38:23 +00:00
MINOR: Mariadb Lineage Fix (#19575)
This commit is contained in:
parent
8c5eee8f07
commit
39eae2dfa5
@ -14,7 +14,7 @@ Mariadb lineage module
|
|||||||
from typing import Optional
|
from typing import Optional
|
||||||
|
|
||||||
from metadata.generated.schema.entity.services.connections.database.mariaDBConnection import (
|
from metadata.generated.schema.entity.services.connections.database.mariaDBConnection import (
|
||||||
MariadbConnection,
|
MariaDBConnection,
|
||||||
)
|
)
|
||||||
from metadata.generated.schema.metadataIngestion.workflow import (
|
from metadata.generated.schema.metadataIngestion.workflow import (
|
||||||
Source as WorkflowSource,
|
Source as WorkflowSource,
|
||||||
@ -38,8 +38,8 @@ class MariadbLineageSource(LineageSource):
|
|||||||
):
|
):
|
||||||
"""Create class instance"""
|
"""Create class instance"""
|
||||||
config: WorkflowSource = WorkflowSource.model_validate(config_dict)
|
config: WorkflowSource = WorkflowSource.model_validate(config_dict)
|
||||||
connection: MariadbConnection = config.serviceConnection.root.config
|
connection: MariaDBConnection = config.serviceConnection.root.config
|
||||||
if not isinstance(connection, MariadbConnection):
|
if not isinstance(connection, MariaDBConnection):
|
||||||
raise InvalidSourceException(
|
raise InvalidSourceException(
|
||||||
f"Expected MariadbConnection, but got {connection}"
|
f"Expected MariadbConnection, but got {connection}"
|
||||||
)
|
)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user