Contexte d'exécution

Accédez aux informations d'exécution du workflow en cours depuis le code du workflow.

Obtenir l'identifiant d'exécution

import mistralai.workflows as workflows

execution_id = workflows.get_execution_id()

import mistralai.workflows as workflows

execution_id = workflows.get_execution_id()

Cela renvoie l'identifiant unique de l'exécution en cours, utile pour la journalisation, la corrélation avec des systèmes externes ou la transmission à des activités devant référencer l'exécution parente.

Exemple d'utilisation

import mistralai.workflows as workflows

@workflows.workflow.define(name="tracked_workflow")
class TrackedWorkflow:
    @workflows.workflow.entrypoint
    async def run(self, params: MyParams) -> MyResult:
        execution_id = workflows.get_execution_id()

        # Pass execution ID to activities for correlation
        result = await process_with_tracking(params, execution_id)
        return result

import mistralai.workflows as workflows

@workflows.workflow.define(name="tracked_workflow")
class TrackedWorkflow:
    @workflows.workflow.entrypoint
    async def run(self, params: MyParams) -> MyResult:
        execution_id = workflows.get_execution_id()

        # Pass execution ID to activities for correlation
        result = await process_with_tracking(params, execution_id)
        return result