The task type
type Task struct {
*protocol.Task[Params]
customState1 string
customState2 int
...
}
func ConstructTask(base *protocol.Task[Params]) (protocol.BaseTask, []flowprotocol.TaskStep, error) {
t := &Task{
Task: base,
...
}
return t,
[]flowprotocol.TaskStep{
{step: t.SomeStep},
...
},
nil
}Last updated