nb_rescheduled = job_client.retry(job)
def JobClient.retry(job_or_id: Job | str) -> int

Retry a job. All failed tasks will become queued again, and queued tasks will be picked up by task runners again.

Parameters

job_or_id
Job | str

The job or job id to retry.

Returns

The number of tasks that were rescheduled.

nb_rescheduled = job_client.retry(job)