Référence des node executors

Chaque type de node dans un flow a un executor correspondant dans services/core/src/application/services/executors/. Ce document détaille chacun d'eux.

AgentNodeExecutor

Fichier : agent_node_executor.py

Envoie un prompt à un LLM et retourne la réponse. Supporte le streaming, le tool calling et plusieurs modes d'exécution.

Configuration

Modes d'exécution

Entrée/Sortie

• Entrée : {{ trigger.message }} ou contexte des nodes précédents
• Sortie : Texte de la réponse LLM (accessible via {{ agent_node.output }})
• Métadonnées : Token usage (prompt tokens, completion tokens), durée, modèle utilisé

ConditionExecutor

Fichier : condition_executor.py

Évalue une expression et dirige le flow vers la branche true ou false.

Configuration

Opérateurs supportés

Le registre complet des opérateurs est dans operator_registry.py.

LoopContainerExecutor

Fichier : loop_container_executor.py

Itère sur une liste et exécute les nodes enfants pour chaque élément.

Configuration

Comportement

1. Évalue items_expression pour obtenir la liste.
2. Pour chaque élément, définit item_variable et index_variable.
3. Exécute les nodes enfants du conteneur.
4. Passe à l'élément suivant.

HTTPRequestExecutor

Fichier : http_request_executor.py

Exécute un appel HTTP vers une API externe.

Configuration

Sortie

{
  "status_code": 200,
  "headers": { "content-type": "application/json" },
  "body": { ... }
}

Sécurité

• Validation SSRF : les URL privées sont bloquées par défaut (127.0.0.1, 10.x.x.x, etc.).
• Les credentials sont résolus depuis le store de secrets, jamais en clair dans la config du node.

CodeExecutor

Fichier : code_executor.py

Exécute du code Python dans un environnement sandboxé.

Configuration

Environnement sandbox

• Imports restreints : pas d'accès fichier, réseau ou OS.
• Variables d'entrée disponibles via le contexte d'exécution.
• Le résultat doit être assigné à la variable result.

# Exemple de code dans le node
data = inputs["agent_output"]
result = {"summary": data[:200], "word_count": len(data.split())}

HumanInputExecutor

Fichier : human_input_executor.py

Met l'exécution en pause et attend une saisie humaine.

Configuration

Comportement

1. L'exécution passe en état waiting_for_input.
2. Un événement SSE human_input_required est émis.
3. L'opérateur voit la demande dans l'interface.
4. Quand l'opérateur répond, l'exécution reprend avec la réponse comme sortie du node.

ParseDocExecutor

Fichier : parse_doc_executor.py

Extrait le texte d'un document (PDF, DOCX, PPTX, HTML).

Configuration

Formats supportés

Sortie

Texte brut extrait du document. La mise en page et les images sont perdues.

MergeDocsExecutor

Fichier : merge_docs_executor.py

Fusionne les sorties texte de plusieurs documents en un seul contenu.

SetVariableExecutor

Fichier : set_variable_executor.py

Définit ou met à jour une variable dans le contexte d'exécution.

Configuration

DirectMessageExecutor

Fichier : direct_message_executor.py

Envoie un message direct à l'utilisateur sans passer par un agent LLM. Utile pour les messages fixes (accueil, erreur, redirection).

Triggers

ManualTriggerExecutor

Fichier : trigger_manual_executor.py

Point d'entrée pour les exécutions manuelles (test, démo). L'utilisateur fournit un message via l'interface.

TriggerFromChannelExecutor

Fichier : trigger_from_channel_executor.py

Point d'entrée pour les exécutions déclenchées depuis un channel (SDK, Webchat, Slack, etc.). Le message provient du canal externe.

Registre des executors

Le NodeExecutorRegistry (application/services/node_executor_registry.py) maintient le mapping node_type → executor_class. Quand le moteur d'exécution rencontre un node, il consulte ce registre pour obtenir l'executor approprié.

Ajouter un nouveau node executor

1. Créer la classe executor dans application/services/executors/.
2. Implémenter la méthode execute() avec la signature standard.
3. Enregistrer le nouveau type dans le NodeExecutorRegistry.
4. Ajouter des tests unitaires et d'intégration.
5. Lancer pnpm generate pour mettre à jour le registre TypeScript côté frontend.

Pour aller plus loin

• Architecture backend — Contexte architectural
• Guide de test — Comment tester les executors