executor

type ChatMessageHandler ¶

type ChatMessageHandler interface {
	SetContext([]exec.LLMMessage)
	GetMessages() []exec.LLMMessage
}

ChatMessageHandler is an interface for executors that handle chat session messages.

type DAGExecutor ¶

type DAGExecutor interface {
	Executor

	// SetParams sets the parameters for running a sub DAG.
	SetParams(RunParams)
}

DAGExecutor is an interface for sub DAG executors.

type DeclaredOutputsProvider ¶

type DeclaredOutputsProvider interface {
	OutputsProvider
	PublishesDeclaredOutputs() bool
}

DeclaredOutputsProvider marks executor outputs as available to strict step output references.

type Executor ¶

type Executor interface {
	SetStdout(out io.Writer)
	SetStderr(out io.Writer)
	Kill(sig os.Signal) error
	Run(ctx context.Context) error
}

Executor is an interface for executing steps in a DAG.

func NewExecutor(ctx context.Context, step core.Step) (Executor, error)

type ExecutorFactory ¶

type ExecutorFactory func(ctx context.Context, step core.Step) (Executor, error)

ExecutorFactory is a function type that creates an Executor based on the step configuration.

type ExitCoder ¶

type ExitCoder interface {
	ExitCode() int
}

ExitCoder is an interface for executors that can return an exit code.

type NodeStatusDeterminer ¶

type NodeStatusDeterminer interface {
	DetermineNodeStatus() (core.NodeStatus, error)
}

NodeStatusDeterminer is an interface for reporting the status of a node execution.

type OutputsProvider ¶

type OutputsProvider interface {
	GetOutputs() map[string]any
}

OutputsProvider is implemented by executors that publish DAG/action outputs.

type ParallelExecutor ¶

type ParallelExecutor interface {
	Executor

	// SetParamsList sets the parameters for running multiple sub DAGs in parallel.
	SetParamsList([]RunParams)
}

ParallelExecutor is an interface for parallel step executors.

type PushBackAware ¶

type PushBackAware interface {
	SetPushBackContext(inputs map[string]string, iteration int)
}

PushBackAware is implemented by executors that can incorporate push-back feedback into their conversation flow.

type PushBackPreviousStdoutAware ¶

type PushBackPreviousStdoutAware interface {
	SetPushBackPreviousStdout(path string)
}

PushBackPreviousStdoutAware is implemented by executors that can consume the previous stdout log path for push-back re-execution.

type RunParams ¶

type RunParams struct {
	RunID          string
	Params         string
	DAGName        string
	WorkerSelector map[string]string
}

RunParams holds the parameters for running a sub DAG.

type Stopper ¶

type Stopper interface {
	Stop(cmdutil.TerminationIntent) error
}

Stopper is implemented by executors that can handle lifecycle stop intent directly instead of receiving only a legacy OS signal.

type SubDAGExecutor ¶

type SubDAGExecutor struct {
	// DAG is the sub DAG to execute.
	// For local DAGs, this DAG's Location will be set to a temporary file.
	DAG *core.DAG
	// contains filtered or unexported fields
}

SubDAGExecutor is a helper for executing sub DAGs. It handles both regular DAGs and local DAGs (defined in the same file).

func NewSubDAGExecutor(ctx context.Context, childName string) (*SubDAGExecutor, error)

func NewSubDAGExecutorForDAG(ctx context.Context, dag *core.DAG) (*SubDAGExecutor, error)

func (e *SubDAGExecutor) Cleanup(ctx context.Context) error

func (e *SubDAGExecutor) Execute(ctx context.Context, runParams RunParams, workDir string) (*exec.RunStatus, error)

func (e *SubDAGExecutor) Kill(sig os.Signal) error

func (e *SubDAGExecutor) Retry(ctx context.Context, runParams RunParams, stepName, workDir string, path exec.RetryPath) (*exec.RunStatus, error)

func (e *SubDAGExecutor) Reuse(ctx context.Context, runParams RunParams, workDir string) (*exec.RunStatus, error)

func (e *SubDAGExecutor) SetExternalStepRetry(enabled bool)

func (e *SubDAGExecutor) SetWorkerSelector(selector map[string]string)

func (e *SubDAGExecutor) SetWorkspaceSeed(seed WorkspaceSeed)

func (e *SubDAGExecutor) Stop(intent cmdutil.TerminationIntent) error

type SubRunProvider ¶

type SubRunProvider interface {
	GetSubRuns() []exec.SubDAGRun
}

SubRunProvider is an interface for executors that spawn sub-DAG runs. This is used by executors like chat (with tools) to report sub-runs for UI drill-down functionality.

type SubWorkflowCancelIntent ¶

type SubWorkflowCancelIntent struct {
	Mode   SubWorkflowCancelMode
	Signal os.Signal
}

SubWorkflowCancelIntent carries runtime-owned cancellation intent.

type SubWorkflowCancelMode ¶

type SubWorkflowCancelMode string

SubWorkflowCancelMode describes how a child workflow should be stopped.

const (
	// SubWorkflowCancelModeGraceful requests a graceful stop of the child workflow.
	SubWorkflowCancelModeGraceful SubWorkflowCancelMode = "graceful"
	// SubWorkflowCancelModeForce requests a forced stop of the child workflow.
	SubWorkflowCancelModeForce SubWorkflowCancelMode = "force"
)

type SubWorkflowCancelRequest ¶

type SubWorkflowCancelRequest struct {
	DAG        *core.DAG
	RootDAGRun exec.DAGRunRef
	RunID      string
	Intent     SubWorkflowCancelIntent
}

SubWorkflowCancelRequest describes a child workflow cancellation.

type SubWorkflowRequest ¶

type SubWorkflowRequest struct {
	DAG               *core.DAG
	ParentDAG         *core.DAG
	RootDAGRun        exec.DAGRunRef
	ParentDAGRun      exec.DAGRunRef
	RunID             string
	Params            string
	ProfileName       string
	TriggerActor      string
	WorkDir           string
	WorkerSelector    map[string]string
	ExternalStepRetry bool
	Reuse             bool
	RetryPath         exec.RetryPath
	Workspace         *SubWorkflowWorkspace
}

SubWorkflowRequest describes a child workflow invocation.

type SubWorkflowRetryRequest ¶

type SubWorkflowRetryRequest struct {
	SubWorkflowRequest
	StepName string
}

SubWorkflowRetryRequest describes a child workflow step retry.

type SubWorkflowRunner ¶

type SubWorkflowRunner interface {
	ShouldRun(ctx context.Context, req SubWorkflowRequest) bool
	Run(ctx context.Context, req SubWorkflowRequest) (*exec.RunStatus, error)
	Retry(ctx context.Context, req SubWorkflowRetryRequest) (*exec.RunStatus, error)
	Cancel(ctx context.Context, req SubWorkflowCancelRequest) error
}

SubWorkflowRunner runs child workflows behind a workflow-level interface.

func SubWorkflowRunnerFromContext(ctx context.Context) (SubWorkflowRunner, bool)

type SubWorkflowWorkspace ¶

type SubWorkflowWorkspace struct {
	Descriptor workspacebundle.Descriptor
	Archive    []byte
}

SubWorkflowWorkspace carries an immutable child workflow workspace.

type TailWriter ¶

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

TailWriter forwards to an underlying writer and keeps a rolling tail of recent output up to `max` bytes. Safe for concurrent use.

func NewTailWriter(out io.Writer, max int) *TailWriter

func NewTailWriterWithEncoding(out io.Writer, max int, encoding string) *TailWriter

func (t *TailWriter) Tail() string

func (t *TailWriter) Write(p []byte) (int, error)

type TaskOption ¶

type TaskOption func(*exec.DispatchTask)

TaskOption is a function that modifies a dispatch task.

func WithBaseConfig(content string) TaskOption

func WithExternalStepRetry(enabled bool) TaskOption

func WithLabels(labels string) TaskOption

func WithParentDagRun(ref exec.DAGRunRef) TaskOption

func WithPreviousStatus(status *exec.DAGRunStatus) TaskOption

func WithProfileName(profileName string) TaskOption

func WithRetryPath(path exec.RetryPath) TaskOption

func WithRootDagRun(ref exec.DAGRunRef) TaskOption

func WithScheduleTime(scheduleTime string) TaskOption

func WithSourceFile(sourceFile string) TaskOption

func WithStep(step string) TaskOption

func WithTags(tags string) TaskOption

func WithTaskParams(params string) TaskOption

func WithTriggerActor(actor string) TaskOption

func WithWorkerSelector(selector map[string]string) TaskOption

func WithWorkspaceBundle(desc workspacebundle.Descriptor) TaskOption

type ToolDefinitionProvider ¶

type ToolDefinitionProvider interface {
	GetToolDefinitions() []exec.ToolDefinition
}

ToolDefinitionProvider is an interface for executors that provide tool definitions. This is used by chat executors to report what tools were available to the LLM for debugging and visibility purposes.

type WorkspaceSeed ¶

type WorkspaceSeed struct {
	Descriptor workspacebundle.Descriptor
	Archive    []byte
}