Content Generation

run = client.trigger_workflow(
    "full-content-pipeline",
    domain_id="4f1e...",
    inputs={
        "target_keyword": "migraine treatment options",
        "composite_min": 80,  # YMYL floor — see the pipeline walkthrough
    },
)

import time
while True:
    state = client.get_run(run["run_id"])
    if state["status"] in ("COMPLETED", "FAILED", "WAITING_APPROVAL"):
        break
    time.sleep(5)

evaluation = state["steps"]["content-evaluation"]["output"]
print(evaluation["overall_confidence"], evaluation["medical_compliance"])

if state["status"] == "WAITING_APPROVAL":
    print("Passed evaluation — awaiting human approval before publish.")
elif evaluation.get("status") == "review_required":
    print("Failed the gate — routed to manual review, not published.")