fixed superset class init (#15761)

This commit is contained in:
Onkar Ravgan 2024-04-01 15:10:08 +05:30 committed by GitHub
parent a64c8493f2
commit 2931798be9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -11,6 +11,8 @@
"""
Superset source module
"""
from typing import Optional
from metadata.generated.schema.entity.services.connections.dashboard.supersetConnection import (
SupersetConnection,
)
@ -32,7 +34,12 @@ class SupersetSource:
"""
@classmethod
def create(cls, config_dict: dict, metadata: OpenMetadata):
def create(
cls,
config_dict: dict,
metadata: OpenMetadata,
pipeline_name: Optional[str] = None,
):
config = WorkflowSource.parse_obj(config_dict)
connection: SupersetConnection = config.serviceConnection.__root__.config
if not isinstance(connection, SupersetConnection):