Method StartWorkflow

api/workflows.go:18–36

(hash, id string, workflowInput map[string]interface{})

}

func (api *API) StartWorkflow(hash, id string, workflowInput map[string]interface{}) error {
	// Create a workflow run
	workflowRunID, err := uuid.NewRandom()
	if err != nil {
		return err
	}
	_, err = api.db.Exec(`INSERT INTO workflow_runs (id, config_hash, workflow_id, started_at)
	VALUES ($1, $2, $3, datetime('now'))`, workflowRunID.String(), hash, id)
	if err != nil {
		return err
	}

	workflow, err := api.GetWorkflow(hash, id)
	if err != nil {
		return err
	}

	return api.ScheduleTask(workflowRunID.String(), workflow.Start, workflowInput)
}

func (api *API) CompleteWorkflowRun(id string, success bool) error {
	_, err := api.db.Exec("UPDATE workflow_runs SET completed_at = datetime('now'), success = $1 WHERE id = $2",