dataflow

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

type DataflowAnalysisNodePersistParams struct {
	AnalysisID      int64
	NodeID          string
	InputHash       string
	NodeName        string
	SampleID        string
	ScriptID        string
	InputsPatterns  map[string]any
	OutputPatterns  map[string]any
	ResolvedInputs  map[string]any
	ResolvedOutputs map[string]any
	// RequestParam carries the node's original request form (analysis.request_param
	// filtered by input handles, with runtime select-assay references written back as
	// {"files": "<id>"}). It is persisted to analysis_node.request_param.
	RequestParam  map[string]any
	UpstreamIDs   []string
	DownstreamIDs []string
	Executor      string
	Retry         int
	MaxRetry      int
	RerunReason   string
	Status        string
	SubmitReason  string
	WorkspaceDir  string
	OutputDir     string
	CommandPath   string
	ParamsPath    string
	LogPath       string
	CacheDir      string
}

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

type DataflowChannelSpec struct {
	ChannelID  string
	FromNodeID string
	ToNodeID   string
	FromPort   string
	ToPort     string
}

type DataflowGraphSpec struct {
	AnalysisID int64
	Processes  []DataflowProcessSpec
	Channels   []DataflowChannelSpec
}

type DataflowOperator interface {
	Notify(ctx context.Context, signal DataflowSignal) error
}

type DataflowProcessRunRequest struct {
	AnalysisID int64
	NodeID     string
	Inputs     map[string]any
	Reason     string
}

type DataflowProcessRuntime interface {
	SubmitProcessInstance(ctx context.Context, req DataflowProcessRunRequest) error
}

type DataflowProcessSpec struct {
	NodeID       string
	NodeName     string
	SampleID     string
	ScriptID     string
	InputKeys    []string
	UpstreamIDs  []string
	Downstream   []string
	Inputs       map[string]any
	Outputs      map[string]any
	ResolvedIn   map[string]any
	ResolvedOut  map[string]any
	Executor     string
	Retry        int
	MaxRetry     int
	RerunReason  string
	OperatorType string
	ScatterField string
	ScatterMode  string
	GatherField  string
	GatherMode   string
}

type DataflowSignal struct {
	ChannelID string
	Value     any
	Closed    bool
}

type GatherOperator struct {
	*BaseOperator
	// contains filtered or unexported fields
}

type InputOperator struct {
	*BaseOperator
	// contains filtered or unexported fields
}

type ScatterOperator struct {
	*BaseOperator
	// contains filtered or unexported fields
}