agent

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

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

type ArtifactFinalizer = runtime.ArtifactFinalizer

type Options struct {
	// Dry is a dry-run mode. It does not execute the actual command.
	// Dry runs do not create persisted history.
	Dry bool
	// NoReuse bypasses manifest hits while retaining staged commits.
	NoReuse bool
	// RetryTarget is the persisted status to retry.
	// If it's specified the agent will execute the DAG with the same
	// configuration as the specified history.
	RetryTarget *ir.DAGRunStatus
	// ParentDAGRun is the dag-run reference of the parent dag-run.
	// It is required for sub dag-runs to identify the parent dag-run.
	ParentDAGRun ir.DAGRunRef
	// ProgressDisplay indicates if the progress display should be shown.
	// This is typically enabled for CLI execution in a TTY environment.
	ProgressDisplay bool
	// ExtraEnvs are additional execution-scoped env vars injected into the DAG run context.
	ExtraEnvs []string
	// WorkDir sets the existing per-run work directory.
	WorkDir string
	// WorkspaceSeed carries the workspace into inline child workflows.
	WorkspaceSeed *runtimeexec.WorkspaceSeed
	// StepRetry is the name of the step to retry, if specified.
	StepRetry string
	// IncludeDownstream resets the selected step and every reachable descendant.
	IncludeDownstream bool
	// RetryPath identifies a persisted child DAG step retry.
	RetryPath dagrun.RetryPath
	// WorkerID is the identifier of the worker executing this DAG run.
	// For distributed execution, this is set to the worker's ID.
	// For local execution, this defaults to "local".
	WorkerID string
	// StatusPusher is used to push status updates to a remote coordinator.
	// When nil, status is written to local filesystem via the run-state attempt.
	StatusPusher StatusPusher
	// SubWorkflowRunnerFactory creates a runner for child workflows.
	SubWorkflowRunnerFactory SubWorkflowRunnerFactory
	// LogWriterFactory is used to create log writers for step output.
	// When nil, logs are written to local filesystem.
	LogWriterFactory runctx.LogWriterFactory
	// QueuedRun indicates this execution is from a queued item.
	// When true, the agent will find the existing dag-run (created by enqueue)
	// instead of creating a new one. This is used for distributed execution
	// where the dag-run directory was already created by the scheduler.
	QueuedRun bool
	// AttemptID uses a caller-assigned attempt identifier when non-empty.
	AttemptID string
	// RunStateStore records execution state for this DAG run.
	RunStateStore runstate.Store
	// StateStore is the persistent state store shared across DAG runs.
	StateStore dagrun.StateStore
	// MaterializationStore coordinates build file materializations.
	MaterializationStore build.MaterializationStore
	// SecretStore resolves local registry refs and runtime profile secrets.
	SecretStore secretpkg.Store
	// SecretReferenceResolver resolves DAG-level registry refs.
	// When nil, SecretStore supplies the local resolver.
	SecretReferenceResolver providers.ReferenceResolver
	// ProfileStore resolves named runtime profiles.
	ProfileStore profilepkg.Store
	// ProfileResolver resolves inherited and selected runtime profile layers.
	ProfileResolver profilepkg.RuntimeResolver
	// ProfileName selects the runtime profile for this DAG run.
	ProfileName string
	// DAGDefinitionID identifies the persisted definition that started this run.
	DAGDefinitionID string
	// ServiceRegistry is the registry for service discovery.
	ServiceRegistry serviceregistry.ServiceRegistry
	// RootDAGRun is the root dag-run reference for sub-DAG runs.
	RootDAGRun ir.DAGRunRef
	// PeerConfig is the configuration for peer communication.
	PeerConfig config.Peer
	// TriggerType indicates how this DAG run was initiated.
	TriggerType ir.TriggerType
	// TriggerActor identifies the attributable actor that initiated the DAG run.
	TriggerActor string
	// ParallelItem is the value bound to ITEM for a parallel child run.
	ParallelItem string
	// DefaultExecMode is the server-level default execution mode.
	DefaultExecMode config.ExecutionMode
	// ScheduleTime is the RFC 3339 timestamp of when this run was scheduled.
	// Set by the scheduler for cron-triggered runs; empty for manual runs.
	ScheduleTime string
	// ArtifactDir is the per-run artifact directory when artifact storage is enabled.
	ArtifactDir string
	// DAGRunLogDir is the base log directory used for child DAG runs created by executors.
	DAGRunLogDir string
	// DAGRunArtifactDir is the base artifact directory used for child DAG runs created by executors.
	DAGRunArtifactDir string
	// ArtifactFinalizer persists artifacts before the final terminal status is written.
	ArtifactFinalizer ArtifactFinalizer
	// RemoteDAGLoader loads a DAG from a remote source when the local repository misses.
	// When nil, no remote fallback is attempted.
	RemoteDAGLoader RemoteDAGLoader
	// SocketServerFactory creates the local status/control transport.
	// When nil, the default Unix socket transport is used.
	SocketServerFactory SocketServerFactory
}

type ProgressReporter interface {
	// Start begins the progress display
	Start()

	// Stop stops the progress display
	Stop()

	// UpdateNode updates the progress for a specific node
	UpdateNode(node *ir.Node)

	// UpdateStatus updates the overall DAG status
	UpdateStatus(status *ir.DAGRunStatus)

	// SetDAGRunInfo sets the DAG run ID and parameters
	SetDAGRunInfo(dagRunID, params string)
}

type RemoteDAGLoader func(ctx context.Context, name string) (*ir.DAG, error)

type Sender interface {
	Send(ctx context.Context, from string, to []string, subject, body string, attachments []string) error
}

type SenderFn func(ctx context.Context, from string, to []string, subject, body string, attachments []string) error

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

type SocketServer interface {
	Serve(ctx context.Context, listen chan error) error
	Shutdown(ctx context.Context) error
}

type SocketServerFactory func(addr string, handlerFunc sock.HTTPHandlerFunc) (SocketServer, error)

type StatusPusher = runtime.StatusPusher

type SubWorkflowRunnerFactory func(ctx context.Context) (runtimeexec.SubWorkflowRunner, error)