Créer un workflow

Les workflows vous permettent d'exécuter des pipelines d'IA multi-étapes, capables de résister aux crashs, aux nouvelles tentatives et aux longues attentes. Votre code s'exécute dans votre environnement ; Mistral gère l'orchestration, l'état et l'observabilité.

À la fin de ce guide de démarrage, vous disposerez d'un workflow opérationnel fonctionnant localement, déclenché depuis la Console Mistral.

Durée estimée : ~15 minutes

• Une clé API Mistral (voir Envoyer votre première requête API si vous n'en avez pas encore)
• Python 3.12 ou version ultérieure
• uv installé (uvx inclut cet outil)

Exécutez la commande suivante dans votre terminal :

uvx mistralai-workflows-cli setup

uvx mistralai-workflows-cli setup

Le CLI crée la structure d'un Projet Python prêt à l'emploi et vous demande la clé API Mistral. Saisissez-la quand cela vous est demandé — elle sera stockée dans la configuration d'environnement du projet.

Ouvrez le dossier généré (nom par défaut : my-workflow) dans votre éditeur.

Ouvrez src/workflows/hello.py. Le projet généré contient un exemple minimal :

from pydantic import BaseModel
import mistralai.workflows as workflows


class HelloInput(BaseModel):
    name: str = "World"


@workflows.activity()
async def greet(name: str) -> str:
    return f"Hello, {name}! Welcome to Mistral Workflows."


@workflows.workflow.define(
    name="hello-world",
    workflow_display_name="Hello World",
    workflow_description="A minimal hello-world workflow.",
)
class HelloWorkflow:
    @workflows.workflow.entrypoint
    async def run(self, input: HelloInput) -> str:
        return await greet(input.name)

from pydantic import BaseModel
import mistralai.workflows as workflows


class HelloInput(BaseModel):
    name: str = "World"


@workflows.activity()
async def greet(name: str) -> str:
    return f"Hello, {name}! Welcome to Mistral Workflows."


@workflows.workflow.define(
    name="hello-world",
    workflow_display_name="Hello World",
    workflow_description="A minimal hello-world workflow.",
)
class HelloWorkflow:
    @workflows.workflow.entrypoint
    async def run(self, input: HelloInput) -> str:
        return await greet(input.name)

À noter :

• @workflows.activity() marque une fonction comme une étape durable. Si le processus est interrompu en cours, la plateforme relance à partir de la dernière activité terminée.
• @workflows.workflow.define enregistre le workflow avec un nom qui vous servira à le déclencher.

Depuis la racine de votre projet, exécutez :

make start-worker

make start-worker

Le worker se connecte à l'API Mistral, enregistre votre workflow, puis attend les tâches à traiter. Laissez ce terminal ouvert.

Tandis que le worker tourne, ouvrez un deuxième terminal et déclenchez une exécution avec la commande Makefile :

make execute workflow=hello-world input='{"name": "World"}'

make execute workflow=hello-world input='{"name": "World"}'

Ou lancez-le depuis la Console Mistral :

1. Accédez à Workflows dans le menu latéral.
2. Sélectionnez hello-world.
3. Cliquez sur Start Workflow et renseignez {"name": "World"} comme entrée.
4. Ouvrez l’onglet Executions pour visualiser l’exécution.

L'exécution se termine par :

{
  "result": "Hello, World! Welcome to Mistral Workflows."
}

{
  "result": "Hello, World! Welcome to Mistral Workflows."
}

Si votre terminal worker affiche une erreur de connexion, vérifiez que votre clé API est bien configurée et que le processus worker est en cours.

Appuyez sur Ctrl+C pour arrêter le worker lorsque vous avez terminé.