workflow

type RunInput struct {
	ParentLocation string                 `json:"parentLocation,omitempty"`
	Location       string                 `json:"location,omitempty"`
	Tasks          []string               `json:"tasks,omitempty"`
	Context        map[string]interface{} `json:"parameters,omitempty"`
	Workflow       *model.Workflow        `json:"workflow,omitempty"`
	Source         []byte                 `json:"source,omitempty"`
	IgnoreError    bool                   `json:"throwError,omitempty"`
	Async          bool                   `json:"wait,omitempty"`
	WaitTimeInMs   int                    `json:"WaitTimeInMs,omitempty"`
}

type RunOutput struct {
	ProcessID string
	Output    map[string]interface{}
	Errors    map[string]string
	State     string
	Trace     *tracing.Trace `json:"trace,omitempty"`
}

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

type StatusInput struct {
	ProcessID string `json:"processID,omitempty"`
}

type StatusOutput struct {
	State  string
	Output map[string]interface{}
}

type WaitInput struct {
	ProcessID         string `json:"processID,omitempty"`
	TimeoutInMs       int    `json:"timeoutSec,omitempty"`
	PoolFrequencyInMs int    `json:"poolTimeMs,omitempty"`
}

type WaitOutput execution.ProcessOutput