From 1a573ebb190355724a721ee132624995f2fe1dc7 Mon Sep 17 00:00:00 2001 From: Maxime Armstrong Date: Fri, 8 Nov 2024 09:19:53 -0500 Subject: [PATCH] Update asset defs --- .../dagster-fivetran/dagster_fivetran/asset_defs.py | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/python_modules/libraries/dagster-fivetran/dagster_fivetran/asset_defs.py b/python_modules/libraries/dagster-fivetran/dagster_fivetran/asset_defs.py index b70d26ae2aa3c..d2617ee2b7c09 100644 --- a/python_modules/libraries/dagster-fivetran/dagster_fivetran/asset_defs.py +++ b/python_modules/libraries/dagster-fivetran/dagster_fivetran/asset_defs.py @@ -164,7 +164,15 @@ def _build_fivetran_assets( ) if not translator_instance or not connection_metadata else translator_instance.get_asset_spec( - FivetranConnectorTableProps(table=table, **connection_metadata._asdict()) + FivetranConnectorTableProps( + table=table, + connector_id=connection_metadata.connector_id, + name=connection_metadata.name, + connector_url=connection_metadata.connector_url, + schema_config=connection_metadata.schemas, + database=connection_metadata.database, + service=connection_metadata.service, + ) ) for table in tracked_asset_keys.keys() ],