Orchestration
Les composants d'orchestration (type ORCH) forment la palette des
workflows : ils déclenchent et
enchaînent des exécutions, plutôt que de transformer des données. Ce qui circule
entre les bricks est un signal de déclenchement, pas un DataFrame.
Trois familles :
Déclencheurs
Un déclencheur démarre le workflow ; il n'a pas d'entrée. La brick Déclencheur est le point d'entrée standard : elle déclare les déclencheurs du workflow (nom + type), dont le runtime (cron, secret webhook, activation, runner) se configure par environnement.
| Brick | Démarrage |
|---|---|
| Déclencheur | Point d'entrée standard : manuel, cron ou webhook, configurés par environnement. |
| Webhook Trigger | Sur appel HTTP entrant (secret + filtre d'IPs). |
| Manual Trigger | À la demande, avec paramètres saisis au lancement. |
| File Watcher | À l'arrivée d'un fichier correspondant à un pattern dans une connexion storage. |
Contrôle de flux
| Brick | Rôle |
|---|---|
| Exécuter un pipeline | Lance un sous-pipeline de données (sorties Success / Fail, passage de variables). |
| Condition | Branche true / false selon une expression booléenne. |
| Attendre | Durée fixe, jusqu'à une heure donnée ou jusqu'à un événement. |
| Pour chaque | Boucle sur une liste ; l'item courant est exposé via ${item}. |
| Parallèle | Lance toutes les branches connectées simultanément (fan-out). |
| Synchronisation | Barrière : attend les branches entrantes (all / any / count). |
| Réessayer | Ré-exécute la branche aval en cas d'échec (backoff fixe ou exponentiel). |
| Gestion d'erreur | Capture l'échec d'une branche et bascule sur un repli. |
| Assertion | Vérifie une condition (contrôle qualité) : stop, route ou avertissement. |
→ Référence du contrôle de flux
Actions
| Brick | Rôle |
|---|---|
| Alerte | Notification unifiée : email, Slack, Teams ou webhook, avec niveau. |
| Définir variable | Stocke une valeur dans le contexte du workflow (${var.workflow.NOM}). |
| Send Email | Envoi d'un email via SMTP. |
| Send Slack | Message Slack (channel ou DM). |
| Send Webhook | Requête HTTP sortante vers un endpoint arbitraire. |
Notifications
Dans un workflow, la brick Alerte est la voie unifiée (elle remplace Send Email / Slack / Webhook). Pour notifier depuis un pipeline de données, utilisez la brick Notification côté chargeurs.