flow

type Edge struct {
	FromID    string
	ToID      string
	Condition *OutputCondition
}

type Flow struct {
	AfterNode   func(nodeID string, node *Node) // optional callback after each node execution, used for checkpointing
	BeforeLevel func() bool                     // optional hook called before each level; return false to stop
	// contains filtered or unexported fields
}

type Node struct {
	ID    string
	Agent *agent.Agent
	Task  string

	Result string
	Error  error
}

type OutputCondition struct {
	Field    string `json:"field"`
	Operator string `json:"operator"`
	Value    string `json:"value"`
}

type Result struct {
	NodeResults    map[string]*Node
	ExecutionOrder []string
}