Update connector data

dagster-io · Nov 8, 2024 · 6c50270 · 6c50270
1 parent dd67908
commit 6c50270
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/python_modules/libraries/dagster-fivetran/dagster_fivetran/resources.py b/python_modules/libraries/dagster-fivetran/dagster_fivetran/resources.py
@@ -649,7 +649,11 @@ def fetch_fivetran_workspace_data(
 
                 schema_config = client.get_schema_config_for_connector(connector_id=connector_id)
 
-                augmented_connector_details = {**connector_details, "schema_config": schema_config}
+                augmented_connector_details = {
+                    **connector_details,
+                    "schema_config": schema_config,
+                    "destination_id": group_id,
+                }
                 connectors.append(
                     FivetranContentData(
                         content_type=FivetranContentType.CONNECTOR,