diff --git a/ingestion/examples/workflows/mysql.json b/ingestion/examples/workflows/mysql.json index d6114df6838..6149ce83c7d 100644 --- a/ingestion/examples/workflows/mysql.json +++ b/ingestion/examples/workflows/mysql.json @@ -7,10 +7,16 @@ "type": "Mysql", "username": "openmetadata_user", "password": "openmetadata_password", - "hostPort": "localhost:3306" + "hostPort": "localhost:3306", + "connectionOptions": {}, + "connectionArguments": {} } }, - "sourceConfig": {"config": {"enableDataProfiler": false}} + "sourceConfig": { + "config": { + "enableDataProfiler": false + } + } }, "sink": { "type": "metadata-rest", diff --git a/ingestion/src/metadata/utils/source_connections.py b/ingestion/src/metadata/utils/source_connections.py index e9a26bb0481..c2fc8d22e19 100644 --- a/ingestion/src/metadata/utils/source_connections.py +++ b/ingestion/src/metadata/utils/source_connections.py @@ -91,7 +91,11 @@ def get_connection_url_common(connection): url += connection.hostPort url += f"/{connection.database}" if connection.database else "" - options = connection.connectionOptions + options = ( + connection.connectionOptions.dict() + if connection.connectionOptions + else connection.connectionOptions + ) if options: if not connection.database: url += "/" diff --git a/ingestion/tests/unit/source/test_mysql.py b/ingestion/tests/unit/source/test_mysql.py index 17b4c6d4c3b..f902ba17093 100644 --- a/ingestion/tests/unit/source/test_mysql.py +++ b/ingestion/tests/unit/source/test_mysql.py @@ -44,7 +44,9 @@ CONFIG = """ "username": "openmetadata_user", "password": "openmetadata_password", "hostPort": "localhost:3306", - "database": "openmetadata_db" + "database": "openmetadata_db", + "connectionOptions": {}, + "connectionArguments": {} } }, "sourceConfig": {