dbt-mcp

import httpx from dbt_mcp.config.config_providers import SemanticLayerConfig from dbt_mcp.gql.errors import raise_gql_error async def submit_request( sl_config: SemanticLayerConfig, payload: dict, ) -> dict: if "variables" not in payload: payload["variables"] = {} payload["variables"]["environmentId"] = sl_config.prod_environment_id async with httpx.AsyncClient() as client: response = await client.post( sl_config.url, json=payload, headers=sl_config.headers_provider.get_headers(), ) response.raise_for_status() result = response.json() raise_gql_error(result) return result