feat(block): Add Dagster block

apps/docs/components/icons.tsx

@@ -124,6 +124,29 @@ export function ConditionalIcon(props: SVGProps<SVGSVGElement>) {
   )
 }
 
+export function CredentialIcon(props: SVGProps<SVGSVGElement>) {
+  return (
+    <svg {...props} viewBox='0 0 24 24' fill='none' xmlns='http://www.w3.org/2000/svg'>
+      <circle cx='8' cy='15' r='4' stroke='currentColor' strokeWidth='1.75' />
+      <path d='M11.83 13.17L20 5' stroke='currentColor' strokeWidth='1.75' strokeLinecap='round' />
+      <path
+        d='M18 7l2 2'
+        stroke='currentColor'
+        strokeWidth='1.75'
+        strokeLinecap='round'
+        strokeLinejoin='round'
+      />
+      <path
+        d='M15 10l2 2'
+        stroke='currentColor'
+        strokeWidth='1.75'
+        strokeLinecap='round'
+        strokeLinejoin='round'
+      />
+    </svg>
+  )
+}
+
 export function NoteIcon(props: SVGProps<SVGSVGElement>) {
   return (
     <svg
@@ -4845,6 +4868,21 @@ export function SSHIcon(props: SVGProps<SVGSVGElement>) {
   )
 }
 
+export function DagsterIcon(props: SVGProps<SVGSVGElement>) {
+  return (
+    <svg {...props} viewBox='0 0 147 147' fill='none' xmlns='http://www.w3.org/2000/svg'>
+      <path
+        d='M73.5 0C32.9 0 0 32.9 0 73.5S32.9 147 73.5 147 147 114.1 147 73.5 114.1 0 73.5 0z'
+        fill='#4F43DD'
+      />
+      <path
+        d='M109.6 52.4L87 39.7c-1.9-1.1-4.3-1.1-6.2 0l-7.3 4.2-7.3-4.2c-1.9-1.1-4.3-1.1-6.2 0L37.4 52.4c-1.9 1.1-3.1 3.1-3.1 5.3v25.4c0 2.2 1.2 4.2 3.1 5.3l7.3 4.2v8.5c0 2.2 1.2 4.2 3.1 5.3l22.6 13.1c1.9 1.1 4.3 1.1 6.2 0l22.6-13.1c1.9-1.1 3.1-3.1 3.1-5.3v-8.5l7.3-4.2c1.9-1.1 3.1-3.1 3.1-5.3V57.7c0-2.2-1.2-4.2-3.1-5.3zm-12 40.4l-16.4 9.5v-8.5l16.4-9.5v8.5zm-6.2-19l-10.2 5.9-10.2-5.9 10.2-5.9 10.2 5.9zm-22.6 27.5l-16.4-9.5v-8.5l16.4 9.5v8.5zm-22.6-35.9l16.4-9.5 10.2 5.9-16.4 9.5-10.2-5.9zm13.1 24.4l-10.2-5.9V75l10.2 5.9v8.9zm22.6 0V81l10.2-5.9v8.8l-10.2 5.9zm9.5-24.4L74.9 74.9l-10.2-5.9 16.4-9.5 10.2 5.9z'
+        fill='white'
+      />
+    </svg>
+  )
+}
+
 export function DatabricksIcon(props: SVGProps<SVGSVGElement>) {
   return (
     <svg {...props} viewBox='0 0 241 266' fill='none' xmlns='http://www.w3.org/2000/svg'>

apps/docs/components/ui/icon-mapping.ts

@@ -30,6 +30,7 @@ import {
   CloudflareIcon,
   ConfluenceIcon,
   CursorIcon,
+  DagsterIcon,
   DatabricksIcon,
   DatadogIcon,
   DevinIcon,
@@ -213,6 +214,7 @@ export const blockTypeToIconMap: Record<string, IconComponent> = {
   cloudflare: CloudflareIcon,
   confluence_v2: ConfluenceIcon,
   cursor_v2: CursorIcon,
+  dagster: DagsterIcon,
   databricks: DatabricksIcon,
   datadog: DatadogIcon,
   devin: DevinIcon,

apps/docs/content/docs/en/tools/dagster.mdx

@@ -0,0 +1,141 @@
+---
+title: Dagster
+description: Orchestrate data pipelines and manage job runs on Dagster+
+---
+
+import { BlockInfoCard } from "@/components/ui/block-info-card"
+
+<BlockInfoCard
+  type="dagster"
+  color="#191A23"
+/>
+
+## Usage Instructions
+
+Connect to Dagster+ to launch job runs, monitor run status, list available jobs across repositories, and terminate in-progress runs. Requires a Dagster Cloud API token.
+
+
+
+## Tools
+
+### `dagster_launch_run`
+
+Launch a Dagster job run in your Dagster+ deployment.
+
+#### Input
+
+| Parameter | Type | Required | Description |
+| --------- | ---- | -------- | ----------- |
+| `organizationName` | string | Yes | Dagster+ organization name \(subdomain, e.g., "myorg"\) |
+| `deploymentName` | string | Yes | Dagster+ deployment name \(e.g., "prod"\) |
+| `apiKey` | string | Yes | Dagster Cloud API token |
+| `repositoryLocationName` | string | Yes | Repository location \(code location\) name |
+| `repositoryName` | string | Yes | Repository name within the code location |
+| `jobName` | string | Yes | Name of the job to launch |
+| `runConfigJson` | string | No | Run configuration as a JSON object \(optional\) |
+| `tags` | string | No | Tags as a JSON array of \{key, value\} objects \(optional\) |
+
+#### Output
+
+| Parameter | Type | Description |
+| --------- | ---- | ----------- |
+| `runId` | string | The globally unique ID of the launched run |
+
+### `dagster_get_run`
+
+Get the status and details of a Dagster run by its ID.
+
+#### Input
+
+| Parameter | Type | Required | Description |
+| --------- | ---- | -------- | ----------- |
+| `organizationName` | string | Yes | Dagster+ organization name \(subdomain\) |
+| `deploymentName` | string | Yes | Dagster+ deployment name \(e.g., "prod"\) |
+| `apiKey` | string | Yes | Dagster Cloud API token |
+| `runId` | string | Yes | The ID of the run to retrieve |
+
+#### Output
+
+| Parameter | Type | Description |
+| --------- | ---- | ----------- |
+| `runId` | string | Run ID |
+| `jobName` | string | Name of the job this run belongs to |
+| `status` | string | Run status \(QUEUED, NOT_STARTED, STARTING, MANAGED, STARTED, SUCCESS, FAILURE, CANCELING, CANCELED\) |
+| `startTime` | number | Run start time as Unix timestamp |
+| `endTime` | number | Run end time as Unix timestamp |
+| `runConfigYaml` | string | Run configuration as YAML |
+| `tags` | json | Run tags as array of \{key, value\} objects |
+
+### `dagster_list_runs`
+
+List recent Dagster runs, optionally filtered by job name.
+
+#### Input
+
+| Parameter | Type | Required | Description |
+| --------- | ---- | -------- | ----------- |
+| `organizationName` | string | Yes | Dagster+ organization name \(subdomain\) |
+| `deploymentName` | string | Yes | Dagster+ deployment name \(e.g., "prod"\) |
+| `apiKey` | string | Yes | Dagster Cloud API token |
+| `jobName` | string | No | Filter runs by job name \(optional\) |
+| `limit` | number | No | Maximum number of runs to return \(default 20\) |
+| `cursor` | string | No | Pagination cursor from a previous list_runs response |
+
+#### Output
+
+| Parameter | Type | Description |
+| --------- | ---- | ----------- |
+| `runs` | json | Array of runs with runId, jobName, status, startTime, endTime |
+|   ↳ `runId` | string | Run ID |
+|   ↳ `jobName` | string | Job name |
+|   ↳ `status` | string | Run status |
+|   ↳ `startTime` | number | Start time as Unix timestamp |
+|   ↳ `endTime` | number | End time as Unix timestamp |
+| `cursor` | string | Pagination cursor to retrieve the next page |
+| `hasMore` | boolean | Whether more runs are available |
+
+### `dagster_list_jobs`
+
+List all jobs across repositories in a Dagster+ deployment.
+
+#### Input
+
+| Parameter | Type | Required | Description |
+| --------- | ---- | -------- | ----------- |
+| `organizationName` | string | Yes | Dagster+ organization name \(subdomain\) |
+| `deploymentName` | string | Yes | Dagster+ deployment name \(e.g., "prod"\) |
+| `apiKey` | string | Yes | Dagster Cloud API token |
+| `repositoryLocationName` | string | No | Filter by repository location name \(optional\) |
+
+#### Output
+
+| Parameter | Type | Description |
+| --------- | ---- | ----------- |
+| `jobs` | json | Array of jobs with name, repositoryName, repositoryLocationName, and description |
+|   ↳ `name` | string | Job name |
+|   ↳ `repositoryName` | string | Repository name |
+|   ↳ `repositoryLocationName` | string | Repository location name |
+|   ↳ `description` | string | Job description |
+
+### `dagster_terminate_run`
+
+Terminate an in-progress Dagster run.
+
+#### Input
+
+| Parameter | Type | Required | Description |
+| --------- | ---- | -------- | ----------- |
+| `organizationName` | string | Yes | Dagster+ organization name \(subdomain\) |
+| `deploymentName` | string | Yes | Dagster+ deployment name \(e.g., "prod"\) |
+| `apiKey` | string | Yes | Dagster Cloud API token |
+| `runId` | string | Yes | The ID of the run to terminate |
+
+#### Output
+
+| Parameter | Type | Description |
+| --------- | ---- | ----------- |
+| `success` | boolean | Whether the run was successfully terminated |
+| `runId` | string | The ID of the terminated run |
+| `message` | string | Error or status message if termination failed |
+
+

apps/docs/content/docs/en/tools/meta.json

@@ -25,6 +25,7 @@
     "cloudflare",
     "confluence",
     "cursor",
+    "dagster",
     "databricks",
     "datadog",
     "devin",

apps/sim/app/(landing)/integrations/data/icon-mapping.ts

@@ -30,6 +30,7 @@ import {
   CloudflareIcon,
   ConfluenceIcon,
   CursorIcon,
+  DagsterIcon,
   DatabricksIcon,
   DatadogIcon,
   DevinIcon,
@@ -213,6 +214,7 @@ export const blockTypeToIconMap: Record<string, IconComponent> = {
   cloudflare: CloudflareIcon,
   confluence_v2: ConfluenceIcon,
   cursor_v2: CursorIcon,
+  dagster: DagsterIcon,
   databricks: DatabricksIcon,
   datadog: DatadogIcon,
   devin: DevinIcon,

apps/sim/app/(landing)/integrations/data/integrations.json

@@ -2243,6 +2243,45 @@
     "integrationType": "developer-tools",
     "tags": ["agentic", "automation"]
   },
+  {
+    "type": "dagster",
+    "slug": "dagster",
+    "name": "Dagster",
+    "description": "Orchestrate data pipelines and manage job runs on Dagster+",
+    "longDescription": "Connect to Dagster+ to launch job runs, monitor run status, list available jobs across repositories, and terminate in-progress runs. Requires a Dagster Cloud API token.",
+    "bgColor": "#191A23",
+    "iconName": "DagsterIcon",
+    "docsUrl": "https://docs.sim.ai/tools/dagster",
+    "operations": [
+      {
+        "name": "Launch Run",
+        "description": "Launch a Dagster job run in your Dagster+ deployment."
+      },
+      {
+        "name": "Get Run",
+        "description": "Get the status and details of a Dagster run by its ID."
+      },
+      {
+        "name": "List Runs",
+        "description": "List recent Dagster runs, optionally filtered by job name."
+      },
+      {
+        "name": "List Jobs",
+        "description": "List all jobs across repositories in a Dagster+ deployment."
+      },
+      {
+        "name": "Terminate Run",
+        "description": "Terminate an in-progress Dagster run."
+      }
+    ],
+    "operationCount": 5,
+    "triggers": [],
+    "triggerCount": 0,
+    "authType": "api-key",
+    "category": "tools",
+    "integrationType": "automation",
+    "tags": ["data-analytics", "cloud", "automation"]
+  },
   {
     "type": "databricks",
     "slug": "databricks",