workflows

type Definition struct {
	Name        string    `json:"name" yaml:"name"`
	Description string    `json:"description,omitempty" yaml:"description,omitempty"`
	Nodes       []Node    `json:"nodes" yaml:"nodes"`
	Edges       []Edge    `json:"edges,omitempty" yaml:"edges,omitempty"`
	Source      string    `json:"source,omitempty" yaml:"-"`
	CreatedAt   time.Time `json:"createdAt" yaml:"-"`
	UpdatedAt   time.Time `json:"updatedAt" yaml:"-"`
}

type Edge struct {
	From string `json:"from" yaml:"from"`
	To   string `json:"to" yaml:"to"`
}

type Node struct {
	ID     string         `json:"id" yaml:"id"`
	Type   string         `json:"type" yaml:"type"`
	Prompt string         `json:"prompt,omitempty" yaml:"prompt,omitempty"`
	Inputs map[string]any `json:"inputs,omitempty" yaml:"inputs,omitempty"`
}

type Run struct {
	ID           string    `json:"id"`
	WorkflowName string    `json:"workflowName"`
	Status       string    `json:"status"`
	ParentRunID  string    `json:"parentRunId,omitempty"`
	CreatedAt    time.Time `json:"createdAt"`
	UpdatedAt    time.Time `json:"updatedAt"`
}

type Store struct {
	Definitions map[string]Definition `json:"definitions"`
	Runs        map[string]Run        `json:"runs"`
	// contains filtered or unexported fields
}