def JobClient.submit(
  job_name: str,
  root_task_or_tasks: Task | Iterable[Task],
  cluster: str | Cluster | Iterable[str | Cluster],
  max_retries: int = 0
) -> Job

​
Parameters

​
job_name
str

The name of the job.

​
root_task_or_tasks
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.

​
cluster
str

The cluster slug for the cluster to run the root task on. In case of multiple root tasks, a list of cluster slugs can be provided.

​
max_retries
int

The maximum number of retries for the subtask in case it fails. Defaults to 0.

Was this page helpful?

JobCache.__iter__JobClient.retry