Dagster TriggerRun
CertifiedTrigger a Dagster job via GraphQL
Dagster TriggerRun
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).
type: io.kestra.plugin.dagster.TriggerRunExamples
Trigger a Dagster job run and wait for completion with Bearer token authentication
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
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
Dagster GraphQL endpoint URL
Dagster Cloud usually exposes https://dagster.cloud/<org>/<deployment>/graphql
jobName *string
Job or pipeline name to trigger
location *string
Repository location name
repository *string
Repository name
body object
GraphQL body with runConfig and tags
Optional runConfig and tags to pass to Dagster; values are rendered before sending
maxDuration string
PT30MMaximum total wait duration
Default 30m; only used when wait is true
options object
HTTP request options
Optional HTTP settings such as headers (e.g., Authorization)
pollFrequency string
PT5SPolling frequency for run status
Default 5s; only used when wait is true
wait booleanstring
falseWait for the job to complete
Defaults to false; when true the task polls until the run reaches a terminal status
Outputs
endTime string
date-timeEnd time of the run
jobName string
Name of the job that was triggered
runId string
Dagster run ID
startTime string
date-timeStart time of the run
status string
Current run status
Possible values: QUEUED, STARTING, STARTED, SUCCESS, FAILURE, CANCELED
