TriggerRun
Launch a Dagster job execution via GraphQL API, poll for status updates, and retrieve the final state.
Launch a Dagster job execution via GraphQL API, poll for status updates, and retrieve the final state.
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.
type: "io.kestra.plugin.dagster.TriggerRun"Examples
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 }}"
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*Requiredstring
The GraphQL API endpoint URL for your Dagster deployment
For Dagster Cloud, this is typically https://dagster.cloud/
jobName*Requiredstring
The job/pipeline name to trigger
location*Requiredstring
The repository location name
repository*Requiredstring
The repository name
bodyobject
Request body containing runConfig and tags
Body of the GraphQL request including run configuration and tags
maxDurationstring
PT30MdurationThe maximum total wait duration
Maximum time to wait for the job to complete when wait is true
optionsobject
HTTP request options including custom headers
Configuration for HTTP client, can include headers like Authorization
pollFrequencystring
PT5SdurationSpecify how often the task should poll for the job run status
Frequency of status checks when wait is true
waitbooleanstring
falseWhether to wait for the job run to complete
Default value is false
Outputs
endTimestring
date-timeThe end time of the run
jobNamestring
The name of the job that was triggered
runIdstring
The Dagster run ID
startTimestring
date-timeThe start time of the run
statusstring
The current status of the run
Possible values: QUEUED, STARTING, STARTED, SUCCESS, FAILURE, CANCELED
