> ## Documentation Index > Fetch the complete documentation index at: https://headgate.mintlify.site/llms.txt > Use this file to discover all available pages before exploring further. # Workflows > Build durable fan-out and fan-in DAGs from ordinary pending jobs. Workflows are an opt-in layer over ordinary jobs. The graph is validated before enqueue, then prepared as one atomic batch containing a coordinator and pending children. Graphs are deliberately bounded: 999 task nodes, 10,000 dependency edges, and 128 bytes per task name. Coordinator ticks read and mutate nodes with a fixed concurrency of 16, so a large valid graph cannot create an unbounded task or connection fan-out. Forged coordinator payloads are revalidated by the worker before any graph operation runs. ```mermaid theme={"system"} flowchart LR E[extract] --> C[customers] E --> O[orders] C --> I[index] O --> I ``` ## Prepare the graph ```rust Rust theme={"system"} let batch = headgate_workflow::Workflow::new("daily-import") .coordinator_queue("workflows") .add("extract", extract, Vec::::new()) .add("customers", customers, ["extract"]) .add("orders", orders, ["extract"]) .add("index", index, ["customers", "orders"]) .prepare()?; store.enqueue(&batch).await?; ``` ```go Go theme={"system"} batch, err := headgateworkflow.New("daily-import"). CoordinatorQueue("workflows"). Add("extract", extract). Add("customers", customers, "extract"). Add("orders", orders, "extract"). Add("index", index, "customers", "orders"). Prepare() if err == nil { err = store.Enqueue(ctx, batch) } ``` ## Run the coordinator Register the coordinator on workers serving its queue, alongside every application task handler. It uses bounded point reads through the inspection capability. ```rust Rust theme={"system"} headgate_workflow::register_coordinator( &mut registry, store.clone(), Duration::from_secs(1), )?; ``` ```go Go theme={"system"} err := headgateworkflow.RegisterCoordinator(registry, store, time.Second) ``` Roots are promoted first. A child becomes available only after every dependency completes. If an upstream job reaches a failed terminal state, descendants that never ran are deleted and the coordinator archives. This first workflow slice is immutable. Signals, timers, graph mutation, nested workflows, and workflow-level retry are not claimed yet.