Dagster

Dagster is an open-source data orchestration platform designed for building, testing, and monitoring data pipelines. It provides a unified model for defining data assets, scheduling jobs, and observing pipeline execution — whether running locally or deployed to Dagster+.

With Dagster, you can:

• Orchestrate data pipelines: Define and run jobs composed of ops and assets with full dependency tracking
• Monitor executions: Track run status, inspect logs, and debug failures step by step
• Manage schedules and sensors: Automate pipeline triggers on a cron schedule or in response to external events
• Reexecute selectively: Resume failed pipelines from the point of failure without rerunning successful steps

In Sim, the Dagster integration enables your agents to interact with a Dagster instance programmatically. Agents can launch and monitor job runs, retrieve execution logs, reexecute failed runs, and manage schedules and sensors — all as part of a larger automated workflow. Use Dagster as an orchestration layer your agents can control and observe, enabling data-driven automation that responds dynamically to pipeline outcomes.

Usage Instructions

Connect to a Dagster instance to launch job runs, monitor run status, list available jobs across repositories, terminate or delete runs, reexecute failed runs, fetch run logs, and manage schedules and sensors. API token only required for Dagster+.

Tools

dagster_launch_run

Launch a job run on a Dagster instance.

Input

Output

dagster_get_run

Get the status and details of a Dagster run by its ID.

Input

Output

dagster_get_run_logs

Fetch execution event logs for a Dagster run.

Input

Output

dagster_list_runs

List recent Dagster runs, optionally filtered by job name.

Input

Output

dagster_list_jobs

List all jobs across repositories in a Dagster instance.

Input

Output

dagster_reexecute_run

Reexecute an existing Dagster run, optionally resuming only from failed steps.

Input

Output

dagster_terminate_run

Terminate an in-progress Dagster run.

Input

Output

dagster_delete_run

Permanently delete a Dagster run record.

Input

Output

dagster_list_schedules

List all schedules in a Dagster repository, optionally filtered by status.

Input

Output

dagster_start_schedule

Enable (start) a schedule in a Dagster repository.

Input

Output

dagster_stop_schedule

Disable (stop) a running schedule in Dagster.

Input

Output

dagster_list_sensors

List all sensors in a Dagster repository, optionally filtered by status.

Input

Output

dagster_start_sensor

Enable (start) a sensor in a Dagster repository.

Input

Output

dagster_stop_sensor

Disable (stop) a running sensor in Dagster.

Input

Output