Aller au contenu principal

Prefect ⇄ Pulse

Intermédiaire ⏱ 10 min prefect · python · task · ✅ exécuté E2E dans le repo

Prefect possède l'orchestration flow/retries ; Pulse est la task de traitement de flux temps réel qu'il appelle. Exemple du repo : examples/prefect-pulse-bridge/ — validé de bout en bout sur Prefect 3.7.8, in-process, sans serveur Prefect.

@flow order_flow → score_via_pulse (@task, retries=2) → decision = escalate | auto-approve

La task fait les deux appels universels :

POST /api/pulse/x/order-scoring/in
GET  /api/pulse/events/order-scoring.score.out

Lancez-le​

pulse server start --dev
mkdir app && cp pulse.yaml app/ && (cd app && pulse deploy .)   # monte order-scoring
pip install prefect requests
python flow.py

Sortie validée​

amount= 2500  ->  high_value=True   decision=escalate
amount=  300  ->  high_value=False  decision=auto-approve

Prefect apporte les retries et l'observabilité ; Pulse apporte les fenêtres par clé, les joins, le dedup, les stages LLM/MCP. Enrichissez le stage score de l'app — le flow n'est pas touché.

Ensuite​