argo

Documentation

Index

• type Workflow
  • func (w *Workflow) Fetch(req *pb.FetchRequest) (*pb.FetchResponse, error)
  • func (w *Workflow) Submit(argoYAMLContent string) (string, error)

Types

type Workflow

type Workflow struct{}

Workflow operates Argo workflow

func (*Workflow) Fetch

func (w *Workflow) Fetch(req *pb.FetchRequest) (*pb.FetchResponse, error)

Fetch fetches the workflow log and status, design doc: https://github.com/sql-machine-learning/sqlflow/blob/develop/doc/design/argo_workflow_on_sqlflow.md

An example of Fetched Responses from the server logs: Step 1/3 Execute Code: echo hello1 Step 1/3 Log: http://localhost:8001/workflows/default/steps-bdpff?nodeId=steps-bdpff-xx1 Step 1/3 Status: Pending Step 1/3 Status: Running Step 1/3 Status: Succeed/Failed Step 2/3 Execute Code: echo hello2 Step 2/3 Log: http://localhost:8001/workflows/default/steps-bdpff?nodeId=steps-bdpff-xx2 ...

func (*Workflow) Submit

func (w *Workflow) Submit(argoYAMLContent string) (string, error)

Submit the Argo workflow and returns the workflow ID