Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunSubgraph ¶
Types ¶
type DAG ¶
type DAG[Node any] struct { // Name of the graph Name string `json:"name"` // Nodes in the graph Nodes map[string]Node `json:"nodes"` // edges in the graph Children map[string][]string `json:"children"` // parents of each node Parents map[string][]string `json:"parents"` }
type TaskNode ¶
type TaskNode struct {
Name string `json:"name"`
Task types.Task `json:"task"`
// Phase represents the current execution state of the task:
// - "pending": Task is registered but waiting for dependencies to complete
// - "waiting": Task's dependencies are satisfied and is ready to execute
// - "starting": Task is initializing but not yet fully running
// - "running": Task is actively executing
// - "stalled": Task is running but not making progress
// - "succeeded": Task completed successfully
// - "failed": Task completed with errors
// - "cancelled": Task was manually stopped
// - "skipped": Task was intentionally not executed
Phase string `json:"phase"`
// the message for the task phase, e.g. "exit code 1'
Message string `json:"message,omitempty"`
// metrics for resource usage tracking
Metrics *types.Metrics `json:"metrics,omitempty"`
// contains filtered or unexported fields
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.