Mistral RunWorkflow

Mistral RunWorkflow
Certified
Run a Mistral Workflow execution

Starts a Mistral Workflow execution via the REST API and optionally waits for it to reach a terminal state.

Note: Mistral Workflows is currently in public preview. Register workflows via the Mistral Python SDK or Studio before using this task.

When wait is true (default), the task polls every pollInterval until the execution completes, fails, or waitTimeout is reached. For long-running workflows (over 15 minutes), set wait: false and use the WorkflowEvents trigger to react to completion.

Terminal success statuses: COMPLETED, CANCELED, CONTINUED_AS_NEW. Terminal failure statuses: FAILED, TIMED_OUT, TERMINATED — these cause the task to throw an exception.

yaml
type: io.kestra.plugin.mistral.RunWorkflow

Examples

Run a Mistral Workflow and wait for completion

yaml
id: mistral_run_workflow
namespace: company.team

tasks:
  - id: run_workflow
    type: io.kestra.plugin.mistral.RunWorkflow
    apiKey: "{{ secret('MISTRAL_API_KEY') }}"
    workflowIdentifier: "my-summarization-workflow"
    input:
      text: "Kestra is an open-source orchestration platform."
      language: "en"
    wait: true
    waitTimeout: PT15M
    pollInterval: PT5S

Fire-and-forget a Mistral Workflow execution

yaml
id: mistral_fire_and_forget
namespace: company.team

tasks:
  - id: start_workflow
    type: io.kestra.plugin.mistral.RunWorkflow
    apiKey: "{{ secret('MISTRAL_API_KEY') }}"
    workflowIdentifier: "my-long-running-workflow"
    input:
      dataset: "kestra://namespace/files/data.csv"
    wait: false

Properties

apiKey *string

API key

Bearer token for the Mistral API; keep in a secret variable.

workflowIdentifier *string

Workflow identifier

The name or ID of the registered Mistral workflow to execute.

baseUrl string

Defaulthttps://api.mistral.ai/v1

Base URL

API base URL; defaults to https://api.mistral.ai/v1.

deploymentName string

Deployment name

Optional deployment name for routing to a specific workflow version.

executionId string

Execution ID

Optional custom execution ID; a UUID is generated by the API when omitted.

input object

Input

Key-value input map passed to the workflow on execution.

pluginDefaultsRef string

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

pollInterval string

DefaultPT5S

Poll interval

How often to poll the execution status when wait is true. Defaults to PT5S.

wait booleanstring

Defaulttrue

Wait for completion

When true, the task polls until the execution reaches a terminal state. Defaults to true.

waitTimeout string

DefaultPT15M

Wait timeout

Maximum duration to wait for a terminal state before throwing a TimeoutException. Defaults to PT15M.

Outputs

endTime string

End time

ISO-8601 timestamp when the execution ended.

executionId string

Execution ID

The ID of the Mistral workflow execution.

result string

Result

JSON-serialized result payload returned by the workflow on successful completion.

startTime string

Start time

ISO-8601 timestamp when the execution started.

status string

Status

Terminal status of the execution (e.g. COMPLETED, FAILED, CANCELED).

totalDurationMs integer

Total duration (ms)

Wall-clock duration in milliseconds from start to end.

DeepSeek

Tasks that call DeepSeek chat models for conversational or schema-guided JSON responses.

Google Cloud

Execute tasks and orchestrate workflows across Google Cloud Platform services. Centralize authentication and resource management for seamless GCP integration.

CloudDataInfrastructureAI

Mistral RunWorkflowCertifiedRun a Mistral Workflow execution

Mistral RunWorkflow

More Plugins in this Category

DeepSeek

Google Cloud

Mistral RunWorkflow
Certified
Run a Mistral Workflow execution