urban-workflow

Moteur de workflow piloté par un langage dédié (DSL) — portage Python de Black-Beard-Sdk/Workflow (.NET), dont le système de normalisation des sorties JSON est remplacé par urban-json (moteur JSLT) : les messages produits par le moteur sont décrits par des templates .jslt déclaratifs, modifiables sans redéploiement.

Un workflow en quelques lignes

NAME ValidationAchat VERSION 1
MATCHING (Type = 'achat')

DEFINE EVENT  DemandeSoumise 'une demande est déposée';
DEFINE RULE   MontantInferieur (DECIMAL seuil) 'montant sous le seuil';
DEFINE ACTION NotifierValideur (TEXT dossier)  'demande d''approbation';
DEFINE CONST  seuil_auto 500 'approbation automatique sous ce montant';

INITIALIZE WORKFLOW
    ON EVENT DemandeSoumise RECURSIVE SWITCH Tri

DEFINE STATE Tri 'aiguillage'
    ON EVENT DemandeSoumise
        WHEN MontantInferieur(seuil = seuil_auto)
            SWITCH Approuvee
        EXECUTE NotifierValideur(dossier = @Workflow.ExternalId)
            SWITCH EnValidation
;
DEFINE STATE Approuvee    'approbation automatique' ;
DEFINE STATE EnValidation 'en attente d''un valideur'
    EXPIRE AFTER 3 DAY SWITCH Expiree
;
DEFINE STATE Expiree      'sans réponse' ;

from urban_workflow import (
    FunctionRegistry, MemoryStorage, Workflow,
    WorkflowEngine, WorkflowFactory, WorkflowProcessor, WorkflowsConfig,
)
from urban_workflow.dsl import parse_config
from urban_workflow.outputs import default_memory_output

rules = FunctionRegistry("rule")
rules.add("MontantInferieur", lambda ctx, seuil: float(
    ctx.incoming_event.extended_datas.get("Montant", 0)) < seuil)

storage = MemoryStorage()
configs = WorkflowsConfig().add_document(parse_config(SCRIPT, rules=rules))
processor = WorkflowProcessor(configs, WorkflowFactory())
processor.load_existing_workflows_by_external_id = (
    lambda key: storage.get_by(Workflow, key, "external_id"))
processor.output_actions = default_memory_output(storage)
engine = WorkflowEngine(processor)

engine.evaluate_event({"Name": "DemandeSoumise", "ExternalId": "DA-42",
                       "Type": "achat", "Montant": 120})

Documentation

English versions: docs/en/dsl-guide.md · docs/en/integration-guide.md · docs/en/testing-guide.md

Playground

Un site web local pour écrire les scripts avec intellisense, diagnostics positionnés, paramétrage des règles métier et simulation d'événements sur le vrai moteur — distribution séparée urban-workflow-playground :

pip install urban-workflow-playground
urban-workflow-playground     # http://127.0.0.1:8777

Installation et développement

pip install -e .[dev]
python3 -m pytest -q

Dépendance unique du cœur : urban-json (qui apporte le runtime ANTLR du parseur DSL). Python ≥ 3.10.

État du portage

Socle, DSL (grammaires ANTLR reprises du source), moteur, templating urban-json et persistance SQL (extra [sql], SQLAlchemy Core) sont fonctionnels et testés (scénarios de bout en bout script DSL → événements → états → messages, cycle de vie persisté en SQL), avec CI GitHub Actions (tests Python 3.10 → 3.13, lint ruff). Les bugs connus du moteur source ne sont pas reproduits — chacun est couvert par un test dédié.

Licence

Voir LICENSE.