Dagster TriggerRun

Dagster TriggerRun

Certified

Trigger a Dagster job via GraphQL

Starts a Dagster job with LaunchPipelineExecution, optionally waits for a terminal status, then returns run metadata. Waiting is disabled by default; when enabled the task polls every pollFrequency (default 5s) until maxDuration (default 30m).

yaml
type: io.kestra.plugin.dagster.TriggerRun

Trigger a Dagster job run and wait for completion with Bearer token authentication

yaml
id: dagster
namespace: company.team

tasks:
  - id: run_dagster_job
    type: io.kestra.plugin.dagster.TriggerRun
    baseUrl: http://localhost:3000/graphql
    jobName: example_job
    repository: __repository__
    location: dagster_quickstart
    wait: true
    pollFrequency: PT1S
    body:
      runConfig:
        ops:
          example_op:
            config:
              param: "value"
      tags:
        source: kestra
        namespace: "{{ flow.namespace }}"
        flow: "{{ flow.id }}"
        task: "{{ task.id }}"
        execution: "{{ execution.id }}"
    options:
      headers:
        Authorization: "Bearer {{ secret('DAGSTER_TOKEN') }}"

Trigger a Dagster job without waiting for completion

yaml
id: dagster_async
namespace: company.team

tasks:
  - id: trigger_job
    type: io.kestra.plugin.dagster.TriggerRun
    baseUrl: https://dagster.cloud/myorg/prod/graphql
    location: my_location
    repository: my_repository
    jobName: my_job
    wait: false
    options:
      headers:
        Authorization: "Bearer {{ secret('DAGSTER_TOKEN') }}"
Properties

Dagster GraphQL endpoint URL

Dagster Cloud usually exposes https://dagster.cloud/<org>/<deployment>/graphql

Job or pipeline name to trigger

Repository location name

Repository name

GraphQL body with runConfig and tags

Optional runConfig and tags to pass to Dagster; values are rendered before sending

DefaultPT30M

Maximum total wait duration

Default 30m; only used when wait is true

HTTP request options

Optional HTTP settings such as headers (e.g., Authorization)

Reference (ref) of the pluginDefaults to apply to this task.

DefaultPT5S

Polling frequency for run status

Default 5s; only used when wait is true

Defaultfalse

Wait for the job to complete

Defaults to false; when true the task polls until the run reaches a terminal status

Formatdate-time

End time of the run

Name of the job that was triggered

Dagster run ID

Formatdate-time

Start time of the run

Current run status

Possible values: QUEUED, STARTING, STARTED, SUCCESS, FAILURE, CANCELED

More Plugins in this Category

Liquibase
Liquibase

Tasks that run Liquibase change management commands.

Data

2 tasks

PostgreSQL
PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

6 tasks

25 blueprints