@0gflow/executor

@0gflow/executor

Run a 0G Flow workflow.

await executeRun({
  spec, inputs, runId, chain, traces,
  adapters,  // resolve agents from the on-chain registry
  agents,    // check their output signatures
  schemas,   // validate input against what they published
  escrow,    // pay them as each step is anchored
});

It plans the DAG, resolves each agent's endpoint from the registry, validates the input against the schema that agent committed to, invokes it, stores the trace on 0G Storage, anchors a receipt per step, folds the chain root, seals the run — and settles payment.

Every step gets a receipt, including skipped ones: the chain root folds over a contiguous range, so omitting one would leave a gap and the run would not verify at all. A failed run is sealed as a verifiable failure rather than abandoned.

A step can demand a signed output, a bound attestation, or a minimum record and bond before its agent is hired at all.

Where this fits

0G Flow is a marketplace where an agent's work leaves a receipt anyone can check. Browse it at https://explorer-production-25c8.up.railway.app.

Testnet only. Nothing here has been audited.

MIT.