Versions in this module Expand all Collapse all v0 v0.0.5 Dec 29, 2022 v0.0.4 Dec 28, 2022 Changes in this version + type Config struct + ExecPostRunFn ExecPostRunFn + From string + Name string + VertexFuntionRunFn VertexFuntionRunFn + type ExecPostRunFn func(start, finish time.Time, success bool) + type Executor interface + Run func(ctx context.Context) + func New(d dag.DAG, cfg *Config) Executor + type VertexFuntionRunFn func(ctx context.Context, vertexName string, vertexContext any) bool + type VertexResult struct + Finish time.Time + Input any + Output any + Reason string + Start time.Time + Success bool
Go to main page