Wait for a Kubernetes Job to complete.
Arguments
Arguments
cluster_id
string
The ID of the cluster.
job_name
string
Name of the job.
location
string
The location that the cluster is hosted in.
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.
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
.
Returns
The completed Kubernetes Job .
Raised exceptions
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.
