workflow.go

package model

import (
	"github.com/pkg/errors"
	"github.com/viant/toolbox/data"
	"github.com/viant/toolbox/url"
)

//Workflow repesents a workflow
type Workflow struct {
	Source *url.Resource //source definition of the workflow
	Data   data.Map      //workflow data
	*AbstractNode
	*TasksNode //workflow task
}

//Validate validates this workflow
func (w *Workflow) Init() error {
	for _, task := range w.Tasks {
		if len(task.Actions) == 0 {
			task.Actions = []*Action{}
			continue
		}
		for _, action := range task.Actions {
			if err := action.Init(); err != nil {
				return err
			}
		}
	}
	return nil
}

//Validate validates this workflow
func (w *Workflow) Validate() error {
	if len(w.Tasks) == 0 {
		return errors.New("tasks were empty")
	}
	if w.DeferredTask != "" {
		if _, err := w.Task(w.DeferredTask); err != nil {
			return err
		}
	}
	if w.OnErrorTask != "" {
		if _, err := w.Task(w.OnErrorTask); err != nil {
			return err
		}
	}

	return nil
}