Jobs.Submit

job, err := client.Jobs.Submit(ctx,
    "My job",
    []workflows.Task{rootTask},
)

job, err := client.Jobs.Submit(ctx,
    "My job",
    []workflows.Task{rootTask},
)

func (*JobClient) Submit(
    ctx context.Context,
    jobName string,
    tasks []workflows.Task,
    options ...job.SubmitOption
) (*workflows.Job, error)

Submit a job.

Parameters

string

The name of the job

[]Task

The root task for the job. This task is executed first and can submit subtasks to manage the entire workflow. A job can have optionally consist of multiple root tasks.

[]job.SubmitOption

Options for the job

Options

default:"0"

Set the maximum number of retries for the subtask in case it fails

default:""

The cluster to run the root task on. If not provided, the default cluster is used.

Returns

A job object.

job, err := client.Jobs.Submit(ctx,
    "My job",
    []workflows.Task{rootTask},
)

Python

Go

Parameters

Options

Returns

​Parameters

​Options

​Returns

Parameters

Options

Returns