Versions in this module Expand all Collapse all v0 v0.92.1 Jun 6, 2026 v0.92.0 Jun 6, 2026 Changes in this version + func DetermineRuntimeType(t *types.Task) string + func LoadFile(path string) (*types.WorkflowMetadata, error) + func ParseYAML(data []byte) (*types.WorkflowMetadata, error) + func ValidateDAG(tasks []types.WorkflowTask) error + func WorkflowTaskToTask(wt types.WorkflowTask) (*types.Task, error) + type ActionInfo struct + CapType string + Details string + IsCapability bool + Operation string + Type string + func ParseAction(action string) ActionInfo + type CheckpointData struct + CompletedTasks map[string]bool + HeartbeatAt time.Time + Input types.KV + StepIndex int + StepResults map[string]string + type Runner struct + func NewRunner() *Runner + func NewRunnerWithStore(store WorkflowRunStore, auditor audit.Auditor, wc *metrics.WorkflowCollector, ...) *Runner + func (r *Runner) Close() error + func (r *Runner) Execute(ctx context.Context, wf types.WorkflowMetadata, input types.KV, file string) error + func (r *Runner) ResumeWorkflow(ctx context.Context, runID int64) error + func (r *Runner) Run(ctx context.Context, t *types.Task) error + type WorkflowRunStore interface + CreateRun func(ctx context.Context, workflowName, workflowFile, triggerType string, ...) (*gen.WorkflowRun, error) + CreateStepRun func(ctx context.Context, runID int64, stepID, stepName, action, actionType string, ...) (*gen.WorkflowStepRun, error) + GetCheckpoint func(ctx context.Context, runID int64, target any) error + GetIncompleteRuns func(ctx context.Context) ([]*gen.WorkflowRun, error) + GetRun func(ctx context.Context, runID int64) (*gen.WorkflowRun, error) + SaveCheckpoint func(ctx context.Context, runID int64, data any) error + UpdateRunHeartbeat func(ctx context.Context, runID int64) error + UpdateRunStatus func(ctx context.Context, runID int64, status int, errMsg string) error + UpdateStepRun func(ctx context.Context, stepRunID int64, status int, result map[string]any, ...) error
Go to main page