wfruntime

Sep 9, 2026

Changes in this version

+ var ErrAsyncClaimLost = errors.New("async task claim is no longer valid")

+ var ErrAsyncResultConflict = errors.New("async task already has a different result")

+ var ErrAsyncRunChanged = errors.New("async task run has changed")

+ var ErrAsyncTaskCancelled = errors.New("async task is cancelled")

+ var ErrAsyncTaskExpired = errors.New("async callback timeout")

+ var ErrAsyncTaskNotFound = errors.New("async task not found")

+ type AsyncResultStore interface

+ CommitAsyncResult func(ctx context.Context, task *AsyncTask, run *WorkflowRun, ...) error

+ type AsyncTask struct

+ ClaimToken string

+ ClaimUntil time.Time

+ CreatedAt time.Time

+ DispatchID string

+ ExpireAt time.Time

+ ExternalTaskID string

+ NodeID string

+ Result *executor.ExecuteResult

+ ResultApplied bool

+ ResultHash string

+ RunID string

+ State AsyncTaskState

+ Task executor.ExecuteTask

+ UpdatedAt time.Time

+ type AsyncTaskState string

+ const AsyncTaskCancelled

+ const AsyncTaskClaimed

+ const AsyncTaskCompleted

+ const AsyncTaskDone

+ const AsyncTaskWaiting

+ type AsyncTaskStore interface

+ AcknowledgeAsyncTask func(ctx context.Context, dispatchID, claimToken string) error

+ CancelAsyncTasks func(ctx context.Context, runID string) error

+ ClaimCompletedAsyncTasks func(ctx context.Context, now time.Time, limit int, lease time.Duration) ([]*AsyncTask, error)

+ ReleaseAsyncTask func(ctx context.Context, dispatchID, claimToken string) error

+ RenewAsyncTask func(ctx context.Context, dispatchID, claimToken string, claimUntil time.Time) (bool, error)

+ SaveAsyncTask func(ctx context.Context, task *AsyncTask) error

+ SubmitAsyncResult func(ctx context.Context, dispatchID string, result executor.ExecuteResult) (bool, error)

type EventType

+ const EventNodeWaiting

type GormStore

+ func (s *GormStore) AcknowledgeAsyncTask(ctx context.Context, dispatchID, claimToken string) error

+ func (s *GormStore) CancelAsyncTasks(ctx context.Context, runID string) error

+ func (s *GormStore) ClaimCompletedAsyncTasks(ctx context.Context, now time.Time, limit int, lease time.Duration) ([]*AsyncTask, error)

+ func (s *GormStore) CommitAsyncResult(ctx context.Context, task *AsyncTask, run *WorkflowRun, ...) error

+ func (s *GormStore) ReleaseAsyncTask(ctx context.Context, dispatchID, claimToken string) error

+ func (s *GormStore) RenewAsyncTask(ctx context.Context, dispatchID, claimToken string, claimUntil time.Time) (bool, error)

+ func (s *GormStore) SaveAsyncTask(ctx context.Context, task *AsyncTask) error

+ func (s *GormStore) SubmitAsyncResult(ctx context.Context, dispatchID string, result executor.ExecuteResult) (bool, error)

type MemoryStore

+ func (s *MemoryStore) AcknowledgeAsyncTask(ctx context.Context, dispatchID, claimToken string) error

+ func (s *MemoryStore) CancelAsyncTasks(_ context.Context, runID string) error

+ func (s *MemoryStore) ClaimCompletedAsyncTasks(_ context.Context, now time.Time, limit int, lease time.Duration) ([]*AsyncTask, error)

+ func (s *MemoryStore) CommitAsyncResult(ctx context.Context, task *AsyncTask, run *WorkflowRun, ...) error

+ func (s *MemoryStore) ReleaseAsyncTask(ctx context.Context, dispatchID, claimToken string) error

+ func (s *MemoryStore) RenewAsyncTask(_ context.Context, dispatchID, claimToken string, claimUntil time.Time) (bool, error)

+ func (s *MemoryStore) SaveAsyncTask(_ context.Context, task *AsyncTask) error

+ func (s *MemoryStore) SubmitAsyncResult(_ context.Context, dispatchID string, result executor.ExecuteResult) (bool, error)

type Status

+ const StatusWaiting

Sep 4, 2026

Changes in this version

type GormStore

+ func NewGormStoreWithTablePrefix(db *gorm.DB, tablePrefix string) (*GormStore, error)

Aug 28, 2026

Changes in this version

type NodeRun

+ DispatchID string

Aug 24, 2026

Changes in this version

+ const InterruptedRunMessage

+ var ErrRunNotFound = errors.New("run not found")

+ func CanTransition(from, to Status) bool

+ func IsTerminal(status Status) bool

+ type EventType string

+ const EventNodeDone

+ const EventNodeFailed

+ const EventNodeLoop

+ const EventNodeReady

+ const EventNodeRetry

+ const EventNodeRunning

+ const EventRunFinished

+ const EventRunPaused

+ const EventRunResumed

+ const EventRunStarted

+ type GormStore struct

+ func NewGormStore(db *gorm.DB) (*GormStore, error)

+ func (s *GormStore) AppendEvent(ctx context.Context, event RunEvent) error

+ func (s *GormStore) Events(ctx context.Context, runID string) ([]RunEvent, error)

+ func (s *GormStore) FailInterruptedRuns(ctx context.Context) (int, error)

+ func (s *GormStore) ListRuns(ctx context.Context) ([]*WorkflowRun, error)

+ func (s *GormStore) LoadRun(ctx context.Context, runID string) (*WorkflowRun, error)

+ func (s *GormStore) SaveRun(ctx context.Context, run *WorkflowRun) error

+ func (s *GormStore) SaveSnapshot(ctx context.Context, snapshot *RunSnapshot) error

+ func (s *GormStore) Snapshots(ctx context.Context, runID string) ([]*RunSnapshot, error)

+ type MemoryStore struct

+ func NewMemoryStore() *MemoryStore

+ func (s *MemoryStore) AppendEvent(_ context.Context, event RunEvent) error

+ func (s *MemoryStore) Events(_ context.Context, runID string) ([]RunEvent, error)

+ func (s *MemoryStore) ListRuns(_ context.Context) ([]*WorkflowRun, error)

+ func (s *MemoryStore) LoadRun(_ context.Context, runID string) (*WorkflowRun, error)

+ func (s *MemoryStore) SaveRun(_ context.Context, run *WorkflowRun) error

+ func (s *MemoryStore) SaveSnapshot(_ context.Context, snapshot *RunSnapshot) error

+ func (s *MemoryStore) Snapshots(_ context.Context, runID string) ([]*RunSnapshot, error)

+ type NodeRun struct

+ Attempt int

+ Error string

+ FinishedAt time.Time

+ Input any

+ MaxAttempts int

+ Metadata map[string]any

+ NodeID string

+ Result any

+ StartedAt time.Time

+ Status Status

+ type RunContext struct

+ NodeResults map[string]any

+ Variables map[string]any

+ type RunEvent struct

+ Message string

+ NodeID string

+ Payload map[string]any

+ RunID string

+ Status Status

+ Time time.Time

+ Type EventType

+ WorkflowID string

+ type RunSnapshot struct

+ At time.Time

+ Context RunContext

+ Description string

+ NodeRuns map[string]*NodeRun

+ RunID string

+ Status Status

+ type Status string

+ const StatusCancelled

+ const StatusFailed

+ const StatusPaused

+ const StatusPending

+ const StatusRetry

+ const StatusRunning

+ const StatusSuccess

+ const StatusTimeout

+ type Store interface

+ AppendEvent func(ctx context.Context, event RunEvent) error

+ Events func(ctx context.Context, runID string) ([]RunEvent, error)

+ ListRuns func(ctx context.Context) ([]*WorkflowRun, error)

+ LoadRun func(ctx context.Context, runID string) (*WorkflowRun, error)

+ SaveRun func(ctx context.Context, run *WorkflowRun) error

+ SaveSnapshot func(ctx context.Context, snapshot *RunSnapshot) error

+ Snapshots func(ctx context.Context, runID string) ([]*RunSnapshot, error)

+ type WorkflowRun struct

+ Context RunContext

+ CreatedAt time.Time

+ CredentialScope string

+ CurrentNodes []string

+ FinishedAt time.Time

+ ID string

+ NodeRuns map[string]*NodeRun

+ PlanID string

+ RequestFingerprint string

+ StartedAt time.Time

+ Status Status

+ UpdatedAt time.Time

+ WorkflowID string

+ WorkflowVersionID string

+ func NewWorkflowRun(runID, workflowID, versionID, planID string) *WorkflowRun

+ func (r *WorkflowRun) Clone() *WorkflowRun