class Google::Apis::ComposerV1beta1::CloudComposerService

Cloud Composer API

Manages Apache Airflow environments on Google Cloud Platform.

@example

require 'google/apis/composer_v1beta1'

Composer = Google::Apis::ComposerV1beta1 # Alias the module
service = Composer::CloudComposerService.new

@see cloud.google.com/composer/

Attributes

key[RW]

@return [String]

API key. Your API key identifies your project and provides you with API access,
quota, and reports. Required unless you provide an OAuth 2.0 token.
quota_user[RW]

@return [String]

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

Public Class Methods

new() click to toggle source
Calls superclass method
# File lib/google/apis/composer_v1beta1/service.rb, line 45
def initialize
  super('https://composer.googleapis.com/', '',
        client_name: 'google-apis-composer_v1beta1',
        client_version: Google::Apis::ComposerV1beta1::GEM_VERSION)
  @batch_path = 'batch'
end

Public Instance Methods

check_environment_upgrade(environment, check_upgrade_request_object = nil, fields: nil, quota_user: nil, options: nil, &block) click to toggle source

Check if an upgrade operation on the environment will succeed. In case of problems detailed info can be found in the returned Operation. @param [String] environment

The resource name of the environment to check upgrade for, in the form: "
projects/`projectId`/locations/`locationId`/environments/`environmentId`"

@param [Google::Apis::ComposerV1beta1::CheckUpgradeRequest] check_upgrade_request_object @param [String] fields

Selector specifying which fields to include in a partial response.

@param [String] quota_user

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

@param [Google::Apis::RequestOptions] options

Request-specific options

@yield [result, err] Result & error if block supplied @yieldparam result [Google::Apis::ComposerV1beta1::Operation] parsed result object @yieldparam err [StandardError] error object if request failed

@return [Google::Apis::ComposerV1beta1::Operation]

@raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification @raise [Google::Apis::AuthorizationError] Authorization is required

# File lib/google/apis/composer_v1beta1/service.rb, line 75
def check_environment_upgrade(environment, check_upgrade_request_object = nil, fields: nil, quota_user: nil, options: nil, &block)
  command = make_simple_command(:post, 'v1beta1/{+environment}:checkUpgrade', options)
  command.request_representation = Google::Apis::ComposerV1beta1::CheckUpgradeRequest::Representation
  command.request_object = check_upgrade_request_object
  command.response_representation = Google::Apis::ComposerV1beta1::Operation::Representation
  command.response_class = Google::Apis::ComposerV1beta1::Operation
  command.params['environment'] = environment unless environment.nil?
  command.query['fields'] = fields unless fields.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
  execute_or_queue_command(command, &block)
end
create_project_location_environment(parent, environment_object = nil, fields: nil, quota_user: nil, options: nil, &block) click to toggle source

Create a new environment. @param [String] parent

The parent must be of the form "projects/`projectId`/locations/`locationId`".

@param [Google::Apis::ComposerV1beta1::Environment] environment_object @param [String] fields

Selector specifying which fields to include in a partial response.

@param [String] quota_user

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

@param [Google::Apis::RequestOptions] options

Request-specific options

@yield [result, err] Result & error if block supplied @yieldparam result [Google::Apis::ComposerV1beta1::Operation] parsed result object @yieldparam err [StandardError] error object if request failed

@return [Google::Apis::ComposerV1beta1::Operation]

@raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification @raise [Google::Apis::AuthorizationError] Authorization is required

# File lib/google/apis/composer_v1beta1/service.rb, line 108
def create_project_location_environment(parent, environment_object = nil, fields: nil, quota_user: nil, options: nil, &block)
  command = make_simple_command(:post, 'v1beta1/{+parent}/environments', options)
  command.request_representation = Google::Apis::ComposerV1beta1::Environment::Representation
  command.request_object = environment_object
  command.response_representation = Google::Apis::ComposerV1beta1::Operation::Representation
  command.response_class = Google::Apis::ComposerV1beta1::Operation
  command.params['parent'] = parent unless parent.nil?
  command.query['fields'] = fields unless fields.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
  execute_or_queue_command(command, &block)
end
delete_project_location_environment(name, fields: nil, quota_user: nil, options: nil, &block) click to toggle source

Delete an environment. @param [String] name

The environment to delete, in the form: "projects/`projectId`/locations/`
locationId`/environments/`environmentId`"

@param [String] fields

Selector specifying which fields to include in a partial response.

@param [String] quota_user

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

@param [Google::Apis::RequestOptions] options

Request-specific options

@yield [result, err] Result & error if block supplied @yieldparam result [Google::Apis::ComposerV1beta1::Operation] parsed result object @yieldparam err [StandardError] error object if request failed

@return [Google::Apis::ComposerV1beta1::Operation]

@raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification @raise [Google::Apis::AuthorizationError] Authorization is required

# File lib/google/apis/composer_v1beta1/service.rb, line 141
def delete_project_location_environment(name, fields: nil, quota_user: nil, options: nil, &block)
  command = make_simple_command(:delete, 'v1beta1/{+name}', options)
  command.response_representation = Google::Apis::ComposerV1beta1::Operation::Representation
  command.response_class = Google::Apis::ComposerV1beta1::Operation
  command.params['name'] = name unless name.nil?
  command.query['fields'] = fields unless fields.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
  execute_or_queue_command(command, &block)
end
delete_project_location_operation(name, fields: nil, quota_user: nil, options: nil, &block) click to toggle source

Deletes a long-running operation. This method indicates that the client is no longer interested in the operation result. It does not cancel the operation. If the server doesn't support this method, it returns `google.rpc.Code. UNIMPLEMENTED`. @param [String] name

The name of the operation resource to be deleted.

@param [String] fields

Selector specifying which fields to include in a partial response.

@param [String] quota_user

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

@param [Google::Apis::RequestOptions] options

Request-specific options

@yield [result, err] Result & error if block supplied @yieldparam result [Google::Apis::ComposerV1beta1::Empty] parsed result object @yieldparam err [StandardError] error object if request failed

@return [Google::Apis::ComposerV1beta1::Empty]

@raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification @raise [Google::Apis::AuthorizationError] Authorization is required

# File lib/google/apis/composer_v1beta1/service.rb, line 438
def delete_project_location_operation(name, fields: nil, quota_user: nil, options: nil, &block)
  command = make_simple_command(:delete, 'v1beta1/{+name}', options)
  command.response_representation = Google::Apis::ComposerV1beta1::Empty::Representation
  command.response_class = Google::Apis::ComposerV1beta1::Empty
  command.params['name'] = name unless name.nil?
  command.query['fields'] = fields unless fields.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
  execute_or_queue_command(command, &block)
end
get_project_location_environment(name, fields: nil, quota_user: nil, options: nil, &block) click to toggle source

Get an existing environment. @param [String] name

The resource name of the environment to get, in the form: "projects/`projectId`
/locations/`locationId`/environments/`environmentId`"

@param [String] fields

Selector specifying which fields to include in a partial response.

@param [String] quota_user

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

@param [Google::Apis::RequestOptions] options

Request-specific options

@yield [result, err] Result & error if block supplied @yieldparam result [Google::Apis::ComposerV1beta1::Environment] parsed result object @yieldparam err [StandardError] error object if request failed

@return [Google::Apis::ComposerV1beta1::Environment]

@raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification @raise [Google::Apis::AuthorizationError] Authorization is required

# File lib/google/apis/composer_v1beta1/service.rb, line 172
def get_project_location_environment(name, fields: nil, quota_user: nil, options: nil, &block)
  command = make_simple_command(:get, 'v1beta1/{+name}', options)
  command.response_representation = Google::Apis::ComposerV1beta1::Environment::Representation
  command.response_class = Google::Apis::ComposerV1beta1::Environment
  command.params['name'] = name unless name.nil?
  command.query['fields'] = fields unless fields.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
  execute_or_queue_command(command, &block)
end
get_project_location_operation(name, fields: nil, quota_user: nil, options: nil, &block) click to toggle source

Gets the latest state of a long-running operation. Clients can use this method to poll the operation result at intervals as recommended by the API service. @param [String] name

The name of the operation resource.

@param [String] fields

Selector specifying which fields to include in a partial response.

@param [String] quota_user

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

@param [Google::Apis::RequestOptions] options

Request-specific options

@yield [result, err] Result & error if block supplied @yieldparam result [Google::Apis::ComposerV1beta1::Operation] parsed result object @yieldparam err [StandardError] error object if request failed

@return [Google::Apis::ComposerV1beta1::Operation]

@raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification @raise [Google::Apis::AuthorizationError] Authorization is required

# File lib/google/apis/composer_v1beta1/service.rb, line 469
def get_project_location_operation(name, fields: nil, quota_user: nil, options: nil, &block)
  command = make_simple_command(:get, 'v1beta1/{+name}', options)
  command.response_representation = Google::Apis::ComposerV1beta1::Operation::Representation
  command.response_class = Google::Apis::ComposerV1beta1::Operation
  command.params['name'] = name unless name.nil?
  command.query['fields'] = fields unless fields.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
  execute_or_queue_command(command, &block)
end
list_project_location_environments(parent, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block) click to toggle source

List environments. @param [String] parent

List environments in the given project and location, in the form: "projects/`
projectId`/locations/`locationId`"

@param [Fixnum] page_size

The maximum number of environments to return.

@param [String] page_token

The next_page_token value returned from a previous List request, if any.

@param [String] fields

Selector specifying which fields to include in a partial response.

@param [String] quota_user

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

@param [Google::Apis::RequestOptions] options

Request-specific options

@yield [result, err] Result & error if block supplied @yieldparam result [Google::Apis::ComposerV1beta1::ListEnvironmentsResponse] parsed result object @yieldparam err [StandardError] error object if request failed

@return [Google::Apis::ComposerV1beta1::ListEnvironmentsResponse]

@raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification @raise [Google::Apis::AuthorizationError] Authorization is required

# File lib/google/apis/composer_v1beta1/service.rb, line 207
def list_project_location_environments(parent, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block)
  command = make_simple_command(:get, 'v1beta1/{+parent}/environments', options)
  command.response_representation = Google::Apis::ComposerV1beta1::ListEnvironmentsResponse::Representation
  command.response_class = Google::Apis::ComposerV1beta1::ListEnvironmentsResponse
  command.params['parent'] = parent unless parent.nil?
  command.query['pageSize'] = page_size unless page_size.nil?
  command.query['pageToken'] = page_token unless page_token.nil?
  command.query['fields'] = fields unless fields.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
  execute_or_queue_command(command, &block)
end
list_project_location_image_versions(parent, include_past_releases: nil, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block) click to toggle source

List ImageVersions for provided location. @param [String] parent

List ImageVersions in the given project and location, in the form: "projects/`
projectId`/locations/`locationId`"

@param [Boolean] include_past_releases

Whether or not image versions from old releases should be included.

@param [Fixnum] page_size

The maximum number of image_versions to return.

@param [String] page_token

The next_page_token value returned from a previous List request, if any.

@param [String] fields

Selector specifying which fields to include in a partial response.

@param [String] quota_user

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

@param [Google::Apis::RequestOptions] options

Request-specific options

@yield [result, err] Result & error if block supplied @yieldparam result [Google::Apis::ComposerV1beta1::ListImageVersionsResponse] parsed result object @yieldparam err [StandardError] error object if request failed

@return [Google::Apis::ComposerV1beta1::ListImageVersionsResponse]

@raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification @raise [Google::Apis::AuthorizationError] Authorization is required

# File lib/google/apis/composer_v1beta1/service.rb, line 402
def list_project_location_image_versions(parent, include_past_releases: nil, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block)
  command = make_simple_command(:get, 'v1beta1/{+parent}/imageVersions', options)
  command.response_representation = Google::Apis::ComposerV1beta1::ListImageVersionsResponse::Representation
  command.response_class = Google::Apis::ComposerV1beta1::ListImageVersionsResponse
  command.params['parent'] = parent unless parent.nil?
  command.query['includePastReleases'] = include_past_releases unless include_past_releases.nil?
  command.query['pageSize'] = page_size unless page_size.nil?
  command.query['pageToken'] = page_token unless page_token.nil?
  command.query['fields'] = fields unless fields.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
  execute_or_queue_command(command, &block)
end
list_project_location_operations(name, filter: nil, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block) click to toggle source

Lists operations that match the specified filter in the request. If the server doesn't support this method, it returns `UNIMPLEMENTED`. NOTE: the `name` binding allows API services to override the binding to use different resource name schemes, such as `users/*/operations`. To override the binding, API services can add a binding such as `“/v1/`name=users/*`/operations”` to their service configuration. For backwards compatibility, the default name includes the operations collection id, however overriding users must ensure the name binding is the parent resource, without the operations collection id. @param [String] name

The name of the operation's parent resource.

@param [String] filter

The standard list filter.

@param [Fixnum] page_size

The standard list page size.

@param [String] page_token

The standard list page token.

@param [String] fields

Selector specifying which fields to include in a partial response.

@param [String] quota_user

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

@param [Google::Apis::RequestOptions] options

Request-specific options

@yield [result, err] Result & error if block supplied @yieldparam result [Google::Apis::ComposerV1beta1::ListOperationsResponse] parsed result object @yieldparam err [StandardError] error object if request failed

@return [Google::Apis::ComposerV1beta1::ListOperationsResponse]

@raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification @raise [Google::Apis::AuthorizationError] Authorization is required

# File lib/google/apis/composer_v1beta1/service.rb, line 512
def list_project_location_operations(name, filter: nil, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block)
  command = make_simple_command(:get, 'v1beta1/{+name}/operations', options)
  command.response_representation = Google::Apis::ComposerV1beta1::ListOperationsResponse::Representation
  command.response_class = Google::Apis::ComposerV1beta1::ListOperationsResponse
  command.params['name'] = name unless name.nil?
  command.query['filter'] = filter unless filter.nil?
  command.query['pageSize'] = page_size unless page_size.nil?
  command.query['pageToken'] = page_token unless page_token.nil?
  command.query['fields'] = fields unless fields.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
  execute_or_queue_command(command, &block)
end
patch_project_location_environment(name, environment_object = nil, update_mask: nil, fields: nil, quota_user: nil, options: nil, &block) click to toggle source

Update an environment. @param [String] name

The relative resource name of the environment to update, in the form: "
projects/`projectId`/locations/`locationId`/environments/`environmentId`"

@param [Google::Apis::ComposerV1beta1::Environment] environment_object @param [String] update_mask

Required. A comma-separated list of paths, relative to `Environment`, of
fields to update. For example, to set the version of scikit-learn to install
in the environment to 0.19.0 and to remove an existing installation of
argparse, the `updateMask` parameter would include the following two `paths`
values: "config.softwareConfig.pypiPackages.scikit-learn" and "config.
softwareConfig.pypiPackages.argparse". The included patch environment would
specify the scikit-learn version as follows: ` "config":` "softwareConfig":` "
pypiPackages":` "scikit-learn":"==0.19.0" ` ` ` ` Note that in the above
example, any existing PyPI packages other than scikit-learn and argparse will
be unaffected. Only one update type may be included in a single request's `
updateMask`. For example, one cannot update both the PyPI packages and labels
in the same request. However, it is possible to update multiple members of a
map field simultaneously in the same request. For example, to set the labels "
label1" and "label2" while clearing "label3" (assuming it already exists), one
can provide the paths "labels.label1", "labels.label2", and "labels.label3"
and populate the patch environment as follows: ` "labels":` "label1":"new-
label1-value" "label2":"new-label2-value" ` ` Note that in the above example,
any existing labels that are not included in the `updateMask` will be
unaffected. It is also possible to replace an entire map field by providing
the map field's path in the `updateMask`. The new value of the field will be
that which is provided in the patch environment. For example, to delete all
pre-existing user-specified PyPI packages and install botocore at version 1.7.
14, the `updateMask` would contain the path "config.softwareConfig.
pypiPackages", and the patch environment would be the following: ` "config":` "
softwareConfig":` "pypiPackages":` "botocore":"==1.7.14" ` ` ` ` **Note:**
Only the following fields can be updated: * `config.softwareConfig.
pypiPackages` * Replace all custom custom PyPI packages. If a replacement
package map is not included in `environment`, all custom PyPI packages are
cleared. It is an error to provide both this mask and a mask specifying an
individual package. * `config.softwareConfig.pypiPackages.`packagename *
Update the custom PyPI package *packagename*, preserving other packages. To
delete the package, include it in `updateMask`, and omit the mapping for it in
`environment.config.softwareConfig.pypiPackages`. It is an error to provide
both a mask of this form and the `config.softwareConfig.pypiPackages` mask. * `
labels` * Replace all environment labels. If a replacement labels map is not
included in `environment`, all labels are cleared. It is an error to provide
both this mask and a mask specifying one or more individual labels. * `labels.`
labelName * Set the label named *labelName*, while preserving other labels. To
delete the label, include it in `updateMask` and omit its mapping in `
environment.labels`. It is an error to provide both a mask of this form and
the `labels` mask. * `config.nodeCount` * Horizontally scale the number of
nodes in the environment. An integer greater than or equal to 3 must be
provided in the `config.nodeCount` field. Supported for Cloud Composer
environments in versions composer-1.*.*-airflow-*.*.*. * `config.
webServerNetworkAccessControl` * Replace the environment's current
WebServerNetworkAccessControl. Supported for Cloud Composer environments in
versions composer-1.*.*-airflow-*.*.*. * `config.softwareConfig.
airflowConfigOverrides` * Replace all Apache Airflow config overrides. If a
replacement config overrides map is not included in `environment`, all config
overrides are cleared. It is an error to provide both this mask and a mask
specifying one or more individual config overrides. * `config.softwareConfig.
airflowConfigOverrides.`section-name * Override the Apache Airflow config
property *name* in the section named *section*, preserving other properties.
To delete the property override, include it in `updateMask` and omit its
mapping in `environment.config.softwareConfig.airflowConfigOverrides`. It is
an error to provide both a mask of this form and the `config.softwareConfig.
airflowConfigOverrides` mask. * `config.softwareConfig.envVariables` * Replace
all environment variables. If a replacement environment variable map is not
included in `environment`, all custom environment variables are cleared. It is
an error to provide both this mask and a mask specifying one or more
individual environment variables. * `config.softwareConfig.imageVersion` *
Upgrade the version of the environment in-place. Refer to `SoftwareConfig.
image_version` for information on how to format the new image version.
Additionally, the new image version cannot effect a version downgrade and must
match the current image version's Composer major version and Airflow major and
minor versions. Consult the [Cloud Composer Version List](https://cloud.google.
com/composer/docs/concepts/versioning/composer-versions) for valid values. * `
config.softwareConfig.schedulerCount` * Horizontally scale the number of
schedulers in Airflow. A positive integer not greater than the number of nodes
must be provided in the `config.softwareConfig.schedulerCount` field.
Supported for Cloud Composer environments in versions composer-1.*.*-airflow-2.
*.*. * `config.databaseConfig.machineType` * Cloud SQL machine type used by
Airflow database. It has to be one of: db-n1-standard-2, db-n1-standard-4, db-
n1-standard-8 or db-n1-standard-16. Supported for Cloud Composer environments
in versions composer-1.*.*-airflow-*.*.*. * `config.webServerConfig.
machineType` * Machine type on which Airflow web server is running. It has to
be one of: composer-n1-webserver-2, composer-n1-webserver-4 or composer-n1-
webserver-8. Supported for Cloud Composer environments in versions composer-1.*
.*-airflow-*.*.*. * `config.maintenanceWindow` * Maintenance window during
which Cloud Composer components may be under maintenance. * `config.
workloadsConfig` * The workloads configuration settings for the GKE cluster
associated with the Cloud Composer environment. Supported for Cloud Composer
environments in versions composer-2.*.*-airflow-*.*.* and newer. * `config.
environmentSize` * The size of the Cloud Composer environment. Supported for
Cloud Composer environments in versions composer-2.*.*-airflow-*.*.* and newer.

@param [String] fields

Selector specifying which fields to include in a partial response.

@param [String] quota_user

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

@param [Google::Apis::RequestOptions] options

Request-specific options

@yield [result, err] Result & error if block supplied @yieldparam result [Google::Apis::ComposerV1beta1::Operation] parsed result object @yieldparam err [StandardError] error object if request failed

@return [Google::Apis::ComposerV1beta1::Operation]

@raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification @raise [Google::Apis::AuthorizationError] Authorization is required

# File lib/google/apis/composer_v1beta1/service.rb, line 327
def patch_project_location_environment(name, environment_object = nil, update_mask: nil, fields: nil, quota_user: nil, options: nil, &block)
  command = make_simple_command(:patch, 'v1beta1/{+name}', options)
  command.request_representation = Google::Apis::ComposerV1beta1::Environment::Representation
  command.request_object = environment_object
  command.response_representation = Google::Apis::ComposerV1beta1::Operation::Representation
  command.response_class = Google::Apis::ComposerV1beta1::Operation
  command.params['name'] = name unless name.nil?
  command.query['updateMask'] = update_mask unless update_mask.nil?
  command.query['fields'] = fields unless fields.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
  execute_or_queue_command(command, &block)
end
restart_environment_web_server(name, restart_web_server_request_object = nil, fields: nil, quota_user: nil, options: nil, &block) click to toggle source

Restart Airflow web server. @param [String] name

The resource name of the environment to restart the web server for, in the
form: "projects/`projectId`/locations/`locationId`/environments/`environmentId`
"

@param [Google::Apis::ComposerV1beta1::RestartWebServerRequest] restart_web_server_request_object @param [String] fields

Selector specifying which fields to include in a partial response.

@param [String] quota_user

Available to use for quota purposes for server-side applications. Can be any
arbitrary string assigned to a user, but should not exceed 40 characters.

@param [Google::Apis::RequestOptions] options

Request-specific options

@yield [result, err] Result & error if block supplied @yieldparam result [Google::Apis::ComposerV1beta1::Operation] parsed result object @yieldparam err [StandardError] error object if request failed

@return [Google::Apis::ComposerV1beta1::Operation]

@raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification @raise [Google::Apis::AuthorizationError] Authorization is required

# File lib/google/apis/composer_v1beta1/service.rb, line 363
def restart_environment_web_server(name, restart_web_server_request_object = nil, fields: nil, quota_user: nil, options: nil, &block)
  command = make_simple_command(:post, 'v1beta1/{+name}:restartWebServer', options)
  command.request_representation = Google::Apis::ComposerV1beta1::RestartWebServerRequest::Representation
  command.request_object = restart_web_server_request_object
  command.response_representation = Google::Apis::ComposerV1beta1::Operation::Representation
  command.response_class = Google::Apis::ComposerV1beta1::Operation
  command.params['name'] = name unless name.nil?
  command.query['fields'] = fields unless fields.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
  execute_or_queue_command(command, &block)
end

Protected Instance Methods

apply_command_defaults(command) click to toggle source
# File lib/google/apis/composer_v1beta1/service.rb, line 527
def apply_command_defaults(command)
  command.query['key'] = key unless key.nil?
  command.query['quotaUser'] = quota_user unless quota_user.nil?
end