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() ],