TriggerRun

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

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