add driver node

app.py

@@ -15,6 +15,26 @@ logging.basicConfig(
 log = logging.getLogger("daggr.micro")
 
 
+import hashlib
+
+def _stamp(*parts) -> str:
+    h = hashlib.sha1("||".join(map(str, parts)).encode("utf-8")).hexdigest()[:10]
+    return h
+
+def _phase(title: str):
+    log.info("========== %s ==========", title)
+
+def _drv(lines, msg: str):
+    log.info("[DRV] %s", msg)
+    lines.append(msg)
+
+def _assert_drv(lines, cond: bool, msg_ok: str, msg_bad: str):
+    if cond:
+        _drv(lines, f"OK   | {msg_ok}")
+    else:
+        _drv(lines, f"FAIL | {msg_bad}")
+
+
 def make_d(seed_d: int, salt_d: int) -> tuple[int, str]:
     run_id = uuid.uuid4().hex[:8]
     t0 = time.time()
@@ -89,6 +109,97 @@ def observe(b_text: str, note: str) -> str:
     return out
 
 
+def driver(run_id: int = 1) -> str:
+    """
+    Driver: exécute une séquence déterministe d'appels Python
+    pour valider la logique (phases 0-3) et produire un rapport.
+    IMPORTANT: ne met pas à jour l'historique UI des nodes D/E/A/B/C.
+    """
+    lines = []
+    sid = _stamp("driver", run_id, time.time_ns())
+    _phase(f"DRIVER start sid={sid}")
+    _drv(lines, f"sid={sid}")
+    _drv(lines, "NOTE: driver calls functions directly; UI history for D/E/A/B/C will NOT change.")
+
+    # ----------------
+    # PH0 baseline
+    # ----------------
+    _phase("PH0 baseline")
+    d0 = make_d(0, 0)
+    e0 = make_e(0, 0)
+    a0 = combine(d0[0], d0[1], e0[0], e0[1], 0.5)
+    b0 = postprocess(a0[0], a0[1], "none", 1)
+    c0 = observe(b0, "hello")
+
+    _drv(lines, f"PH0 | D={d0} | E={e0}")
+    _drv(lines, f"PH0 | A(mix,summary)={a0}")
+    _drv(lines, f"PH0 | B(text)={b0}")
+    _drv(lines, f"PH0 | C(text)={c0}")
+
+    # invariants simples
+    _assert_drv(lines, isinstance(a0[0], int), "A.mix is int", f"A.mix not int: {type(a0[0])}")
+    _assert_drv(lines, "alpha=0.50" in a0[1], "A.summary contains alpha", "A.summary missing alpha")
+    _assert_drv(lines, "mix=" in a0[1], "A.summary contains mix", "A.summary missing mix")
+
+    # ----------------
+    # PH1A D versions
+    # ----------------
+    _phase("PH1A D versions (E fixed)")
+    for sd in [1, 2]:
+        d = make_d(sd, 0)
+        a = combine(d[0], d[1], e0[0], e0[1], 0.5)
+        _drv(lines, f"PH1A | seed_d={sd} => D={d} | A={a}")
+        _assert_drv(lines, a[0] == int(d[0] * 0.5 + e0[0] * 0.5), "A.mix matches weighted sum", "A.mix mismatch")
+
+    # ----------------
+    # PH1B E versions (D fixed)
+    # ----------------
+    _phase("PH1B E versions (D fixed to seed=2)")
+    d2 = make_d(2, 0)
+    for se in [1, 2]:
+        e = make_e(se, 0)
+        a = combine(d2[0], d2[1], e[0], e[1], 0.5)
+        _drv(lines, f"PH1B | seed_e={se} => E={e} | A={a}")
+        _assert_drv(lines, a[0] == int(d2[0] * 0.5 + e[0] * 0.5), "A.mix matches weighted sum", "A.mix mismatch")
+
+    # ----------------
+    # PH2 alpha variations (same upstream pair)
+    # ----------------
+    _phase("PH2 alpha variations (D=2,E=1)")
+    d = make_d(2, 0)
+    e = make_e(1, 0)
+    for alpha in [0.2, 0.8, 0.35]:
+        a = combine(d[0], d[1], e[0], e[1], alpha)
+        _drv(lines, f"PH2 | alpha={alpha:.2f} => A={a}")
+        _assert_drv(lines, f"alpha={alpha:.2f}" in a[1], "A.summary alpha matches", "A.summary alpha mismatch")
+
+    # ----------------
+    # PH3 downstream noise
+    # ----------------
+    _phase("PH3 downstream noise")
+    a = combine(d[0], d[1], e[0], e[1], 0.35)
+    for mode, bump in [("add", 1), ("add", 2), ("mul", 2)]:
+        b = postprocess(a[0], a[1], mode, bump)
+        c = observe(b, f"note-{mode}-{bump}")
+        _drv(lines, f"PH3 | B({mode},{bump}) => {b}")
+        _drv(lines, f"PH3 | C(note-{mode}-{bump}) => {c}")
+
+    _phase(f"DRIVER done sid={sid}")
+    return "\n".join(lines)
+
+
+DRIVER = FnNode(
+    fn=driver,
+    inputs={
+        "run_id": gr.Slider(label="Driver run_id", minimum=1, maximum=20, step=1, value=1),
+    },
+    outputs={
+        "report": gr.Textbox(label="Driver report", lines=30),
+    },
+)
+
+
+
 D = FnNode(
     fn=make_d,
     inputs={
@@ -148,7 +259,11 @@ C = FnNode(
     outputs={"c_text": gr.Textbox(label="C text")},
 )
 
-graph = Graph(name="micro-restore-debug-nojson", nodes=[D, E, A, B, C], persist_key=False)
+graph = Graph(
+    name="micro-restore-debug-nojson",
+    nodes=[D, E, A, B, C, DRIVER],
+    persist_key=False,
+)
 
 port = int(os.getenv("PORT", "7860"))
 graph.launch(host="0.0.0.0", port=port, open_browser=False, log_level="debug", access_log=True)