Aller au contenu principal

Classe Run

La classe Run représente une instance d’exécution de Workflow et fournit des méthodes pour démarrer, reprendre, streamer et surveiller l’exécution d’un Workflow.

Exemple d’utilisation
Lien direct vers Exemple d’utilisation

const run = await workflow.createRun()

const result = await run.start({
inputData: { value: 'initial data' },
})

if (result.status === 'suspended') {
const resumedResult = await run.resume({
resumeData: { value: 'resume data' },
})
}

Méthodes de Run
Lien direct vers Méthodes de Run

start:

(options?: StartOptions) => Promise<WorkflowResult>
Démarre l’exécution du Workflow avec des données d’entrée

resume:

(options?: ResumeOptions) => Promise<WorkflowResult>
Reprend un Workflow suspendu à partir d’une étape spécifique

stream:

(options?: StreamOptions) => MastraWorkflowStream
Surveille l’exécution du Workflow sous forme de flux d’événements doté de fonctionnalités de streaming améliorées

resumeStream:

(options?: ResumeStreamOptions) => MastraWorkflowStream
Reprend un Workflow suspendu avec prise en charge du streaming

cancel:

() => Promise<{ message: string }>
Annule l’exécution du Workflow, arrête les étapes en cours et empêche l’exécution des étapes suivantes

restart:

(options?: RestartOptions) => Promise<WorkflowResult>
Redémarre l’exécution du Workflow à partir de la dernière étape active

timeTravel:

(options?: TimeTravelOptions) => Promise<WorkflowResult>
Réexécute un Workflow à partir de n’importe quelle étape spécifique, en utilisant les données d’un instantané stocké ou le contexte personnalisé que vous fournissez.

timeTravelStream:

(options?: TimeTravelOptions) => MastraWorkflowStream
Effectue un time travel sur une exécution de Workflow avec prise en charge du streaming

État de Run
Lien direct vers État de Run

Le status d’une exécution de Workflow indique son état d’exécution actuel. Les valeurs possibles sont :

success:

string
Toutes les étapes se sont terminées avec succès, avec une sortie de résultat valide

failed:

string
L’exécution du Workflow a rencontré une erreur, dont les détails sont disponibles

suspended:

string
L’exécution du Workflow est suspendue en attente de reprise, avec les informations des étapes suspendues

canceled:

string
L’exécution du Workflow a été annulée via la méthode cancel(), ce qui arrête les étapes en cours et empêche l’exécution des étapes suivantes