Update asset defs

dagster-io · Nov 8, 2024 · 34aa340 · 34aa340
1 parent 6c0dfa3
commit 34aa340
Showing 1 changed file with 9 additions and 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
@@ -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()
         ],