Function: gke.await_job

Wait for a Kubernetes Job to complete.

Arguments

Arguments
`cluster_id`	`string` The ID of the cluster.
`job_name`	`string` Name of the job.
`namespace`	`string` The namespace of the job (default: `default`).
`project`	`string` The project that the cluster is hosted in. Default value is this workflow's project.
`location`	`string` The location that the cluster is hosted in. Default value is this workflow's location.
`query`	Optional query parameters for fetching the job. If present, must be a map of simple types that will be URL-encoded and appended to the URL. For more information, see Kubernetes API reference.
`timeout`	`float` The timeout, in seconds (default: `1800.0`). If the job doesn't complete within the timeout, a `TimeoutError` is raised. The maximum allowed timeout is one year.
`polling_policy`	`dict` Policy for polling the job's status. Supported fields are `initial_delay`, `max_delay`, and `multiplier`. For details, see Connectors reference.

The completed Kubernetes Job.

Exceptions
`ConnectionError`	In case of a network problem (DNS failure, refused connection, etc.).
`TimeoutError`	When the specified timeout is reached before the response is received.
`HttpError`	If the response status is >= 400.
`ValueError`	If the cluster does not have status `RUNNING`.
`FailedJobError`	If the job failed.

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2024-11-19 UTC.