diff --git a/python_modules/libraries/dagster-fivetran/dagster_fivetran/resources.py b/python_modules/libraries/dagster-fivetran/dagster_fivetran/resources.py index ef4acdc929d11..8cd31ae02718a 100644 --- 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,