Dagster MCP MCP Server

About

## Dagster MCP Server: Data Orchestration The **Dagster MCP Server** integrates Dagster's modern data orchestration platform into Google Antigravity. This enables building observable, testable data pipelines with a focus on developer experience and software engineering best practices. ### Why Dagster MCP? Dagster modernizes data engineering: - **Software-Defined Assets**: Data as first-class citizens - **Type System**: Data validation built-in - **Observability**: Rich lineage and metadata - **Testing**: Unit test your pipelines - **Cloud Native**: Dagster Cloud or self-hosted ### Key Features #### 1. Launch Runs ```python import requests headers = {"Dagster-Cloud-Api-Token": api_token} # Launch job run response = requests.post( "https://your-org.dagster.cloud/graphql", headers=headers, json={ "query": """ mutation LaunchRun($selector: JobSelector!) { launchRun(executionParams: {selector: $selector}) { run { runId status } } } """, "variables": {"selector": {"jobName": "daily_etl"}} } ) ``` #### 2. Query Assets ```python # Get asset materializations response = requests.post( "https://your-org.dagster.cloud/graphql", headers=headers, json={ "query": """ query AssetMaterializations($assetKey: AssetKeyInput!) { assetOrError(assetKey: $assetKey) { ... on Asset { assetMaterializations(limit: 10) { timestamp runId } } } } """, "variables": {"assetKey": {"path": ["users_table"]}} } ) ``` #### 3. Monitor Runs ```python # Get run status response = requests.post( "https://your-org.dagster.cloud/graphql", headers=headers, json={ "query": """ query RunStatus($runId: ID!) { runOrError(runId: $runId) { ... on Run { status stats { stepsSucceeded stepsFailed } } } } """, "variables": {"runId": run_id} } ) ``` ### Configuration ```json { "mcpServers": { "dagster": { "command": "npx", "args": ["-y", "@anthropic/mcp-dagster"], "env": { "DAGSTER_CLOUD_URL": "https://your-org.dagster.cloud", "DAGSTER_CLOUD_API_TOKEN": "your-token" } } } } ``` ### Use Cases **Data Pipelines**: Modern ETL with observability. **Asset Management**: Track data dependencies. **Data Quality**: Built-in validation and testing. The Dagster MCP Server brings modern data orchestration to Antigravity.

Installation

{
  "mcpServers": {
    "dagster": {}
  }
}

How to Use