workflow

type AgentRunner interface {
	Run(ctx context.Context, sessionKey string, prompt string) (string, error)
}

type ChannelSender interface {
	SendMessage(ctx context.Context, channel string, message string) error
}

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

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

type RunResult struct {
	RunID        string
	WorkflowName string
	Status       string
	StepResults  map[string]string // stepID -> result
	Error        string
	StartedAt    time.Time
	CompletedAt  time.Time
}

type RunStatus struct {
	RunID          string
	WorkflowName   string
	Status         string
	TotalSteps     int
	CompletedSteps int
	StartedAt      time.Time
	StepStatuses   []StepStatus
}

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

type Step struct {
	ID        string        `yaml:"id"`
	Agent     string        `yaml:"agent"`  // executor | researcher | planner | memory-manager
	Prompt    string        `yaml:"prompt"` // Go template with {{step-id.result}}
	DependsOn []string      `yaml:"depends_on"`
	DeliverTo []string      `yaml:"deliver_to"` // per-step delivery
	Timeout   time.Duration `yaml:"timeout"`
}

type StepStatus struct {
	StepID string
	Agent  string
	Status string
	Error  string
}

type Workflow struct {
	Name        string   `yaml:"name"`
	Description string   `yaml:"description"`
	Schedule    string   `yaml:"schedule"`   // optional cron expression
	DeliverTo   []string `yaml:"deliver_to"` // optional result delivery targets
	Steps       []Step   `yaml:"steps"`
}