TriggerRun

Trigger a Dagster job run and optionally wait for completion.

Launch a Dagster job execution via GraphQL API, poll for status updates, and retrieve the final state.

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

Examples

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 }}"

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

baseUrl *string

The GraphQL API endpoint URL for your Dagster deployment

For Dagster Cloud, this is typically https://dagster.cloud///graphql

jobName *string

The job/pipeline name to trigger

location *string

The repository location name

repository *string

The repository name

body object

Request body containing runConfig and tags

Body of the GraphQL request including run configuration and tags

maxDuration string

Default PT30M

Format duration

The maximum total wait duration

Maximum time to wait for the job to complete when wait is true

options object

HTTP request options including custom headers

Configuration for HTTP client, can include headers like Authorization

pollFrequency string

Default PT5S

Format duration

Specify how often the task should poll for the job run status

Frequency of status checks when wait is true

wait booleanstring

Default false

Whether to wait for the job run to complete

Default value is false

Outputs

endTime string

Format date-time

The end time of the run

jobName string

The name of the job that was triggered

runId string

The Dagster run ID

startTime string

Format date-time

The start time of the run

status string

The current status of the run

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

​Trigger​Run

TriggerRun