workflow

type DBOSOrchestrator struct {
	// contains filtered or unexported fields
}

type GitManager interface {
	// Create creates a new worktree for a task and returns the worktree path.
	Create(task *types.Task) (string, error)

	// Commit commits changes for a task and returns whether there were changes.
	Commit(taskID, message string) (bool, error)

	// MergeToMain merges the worktree changes to the main branch.
	MergeToMain(taskID string) error

	// Remove cleans up a worktree for a task.
	Remove(taskID string) error

	// Cleanup cleans up all worktrees.
	Cleanup() error

	// SetVerbose enables or disables verbose logging.
	SetVerbose(v bool)

	// PruneStale cleans up stale worktree artifacts for a task.
	PruneStale(taskID string)

	// GetWorktreePath returns the filesystem path for a task's worktree.
	GetWorktreePath(taskID string) (string, error)
}

type Orchestrator struct {
	// contains filtered or unexported fields
}

type QueueStats struct {
	TotalEnqueued int
	Completed     int
	Failed        int
	Duration      time.Duration
}

type QueuedTasksInput struct {
	Tasks []TaskInput
}

type TaskInput struct {
	TaskID      string
	Title       string
	Description string
	EpicID      string
	Priority    int
	MaxAttempts int
	// BlockedBy lists task IDs that must complete before this task can run
	BlockedBy []string
}

type TaskResult struct {
	Success    bool
	Output     string
	Error      string
	Duration   time.Duration
	HasChanges bool
	CommitHash string
}