`airflow.contrib.hooks.gcp_cloud_build_hook`¶

Hook for Google Cloud Build service

Module Contents¶

airflow.contrib.hooks.gcp_cloud_build_hook.TIME_TO_SLEEP_IN_SECONDS = 5[source]¶

class airflow.contrib.hooks.gcp_cloud_build_hook.CloudBuildHook(api_version='v1', gcp_conn_id='google_cloud_default', delegate_to=None)[source]¶

Bases: airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook

Hook for the Google Cloud Build APIs.

All the methods in the hook where project_id is used must be called with keyword arguments rather than positional.

Parameters

api_version (str) – API version used (for example v1 or v1beta1).
gcp_conn_id (str) – The connection ID to use when fetching connection info.
delegate_to (str) – The account to impersonate, if any. For this to work, the service account making the request must have domain-wide delegation enabled.

_conn[source]¶

get_conn(self)[source]¶

Retrieves the connection to Cloud Functions.

Returns: Google Cloud Build services object.

create_build(self, body, project_id=None)[source]¶

Starts a build with the specified configuration.

Parameters

body (dict) – The request body. See: https://cloud.google.com/cloud-build/docs/api/reference/rest/Shared.Types/Build
project_id (str) – Optional, Google Cloud Project project_id where the function belongs. If set to None or missing, the default project_id from the GCP connection is used.

Returns

None

_wait_for_operation_to_complete(self, operation_name)[source]¶

Waits for the named operation to complete - checks status of the asynchronous call.

Parameters: operation_name (str) – The name of the operation.
Returns: The response returned by the operation.
Return type: dict
Exception: AirflowException in case error is returned.

airflow.contrib.hooks.gcp_cloud_build_hook¶

Module Contents¶

`airflow.contrib.hooks.gcp_cloud_build_hook`¶