Function execute_workflow

src/workflow/sandbox.py:180–185

Compile + run the script, returning its top-level ``return`` value.

(source: str, primitives: Mapping[str, Any], args: Any)

async def execute_workflow(source: str, primitives: Mapping[str, Any], args: Any) -> Any:
    """Compile + run the script, returning its top-level ``return`` value."""
    code = compile_workflow(source)
    namespace = build_namespace(primitives, args)
    exec(code, namespace)  # noqa: S102 — curated namespace; see module docstring
    return await namespace[_WRAPPER_NAME]()