lib/google/cloud/dataform/v1beta1/dataform/rest/service_stub.rb in google-cloud-dataform-v1beta1-0.7.1 vs lib/google/cloud/dataform/v1beta1/dataform/rest/service_stub.rb in google-cloud-dataform-v1beta1-0.8.0
- old
+ new
@@ -28,21 +28,24 @@
# REST service stub for the Dataform service.
# Service stub contains baseline method implementations
# including transcoding, making the REST call, and deserialing the response.
#
class ServiceStub
- def initialize endpoint:, endpoint_template:, universe_domain:, credentials:
+ # @private
+ def initialize endpoint:, endpoint_template:, universe_domain:, credentials:, logger:
# These require statements are intentionally placed here to initialize
# the REST modules only when it's required.
require "gapic/rest"
@client_stub = ::Gapic::Rest::ClientStub.new endpoint: endpoint,
endpoint_template: endpoint_template,
universe_domain: universe_domain,
credentials: credentials,
numeric_enums: true,
- raise_faraday_errors: false
+ service_name: self.class,
+ raise_faraday_errors: false,
+ logger: logger
end
##
# The effective universe domain
#
@@ -60,10 +63,19 @@
def endpoint
@client_stub.endpoint
end
##
+ # The logger used for request/response debug logging.
+ #
+ # @return [Logger]
+ #
+ def logger stub: false
+ stub ? @client_stub.stub_logger : @client_stub.logger
+ end
+
+ ##
# Baseline implementation for the list_repositories REST call
#
# @param request_pb [::Google::Cloud::Dataform::V1beta1::ListRepositoriesRequest]
# A request object representing the call parameters. Required.
# @param options [::Gapic::CallOptions]
@@ -85,20 +97,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "list_repositories",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ListRepositoriesResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the get_repository REST call
#
@@ -123,20 +137,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "get_repository",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::Repository.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the create_repository REST call
#
@@ -161,20 +177,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "create_repository",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::Repository.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the update_repository REST call
#
@@ -199,20 +217,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "update_repository",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::Repository.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the delete_repository REST call
#
@@ -237,20 +257,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "delete_repository",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the commit_repository_changes REST call
#
@@ -275,20 +297,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "commit_repository_changes",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the read_repository_file REST call
#
@@ -313,20 +337,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "read_repository_file",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ReadRepositoryFileResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the query_repository_directory_contents REST call
#
@@ -351,20 +377,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "query_repository_directory_contents",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::QueryRepositoryDirectoryContentsResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the fetch_repository_history REST call
#
@@ -389,20 +417,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "fetch_repository_history",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::FetchRepositoryHistoryResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the compute_repository_access_token_status REST call
#
@@ -427,20 +457,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "compute_repository_access_token_status",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ComputeRepositoryAccessTokenStatusResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the fetch_remote_branches REST call
#
@@ -465,20 +497,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "fetch_remote_branches",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::FetchRemoteBranchesResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the list_workspaces REST call
#
@@ -503,20 +537,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "list_workspaces",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ListWorkspacesResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the get_workspace REST call
#
@@ -541,20 +577,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "get_workspace",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::Workspace.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the create_workspace REST call
#
@@ -579,20 +617,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "create_workspace",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::Workspace.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the delete_workspace REST call
#
@@ -617,20 +657,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "delete_workspace",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the install_npm_packages REST call
#
@@ -655,20 +697,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "install_npm_packages",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::InstallNpmPackagesResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the pull_git_commits REST call
#
@@ -693,20 +737,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "pull_git_commits",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the push_git_commits REST call
#
@@ -731,20 +777,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "push_git_commits",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the fetch_file_git_statuses REST call
#
@@ -769,20 +817,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "fetch_file_git_statuses",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::FetchFileGitStatusesResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the fetch_git_ahead_behind REST call
#
@@ -807,20 +857,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "fetch_git_ahead_behind",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::FetchGitAheadBehindResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the commit_workspace_changes REST call
#
@@ -845,20 +897,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "commit_workspace_changes",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the reset_workspace_changes REST call
#
@@ -883,20 +937,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "reset_workspace_changes",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the fetch_file_diff REST call
#
@@ -921,20 +977,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "fetch_file_diff",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::FetchFileDiffResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the query_directory_contents REST call
#
@@ -959,20 +1017,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "query_directory_contents",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::QueryDirectoryContentsResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the make_directory REST call
#
@@ -997,20 +1057,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "make_directory",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::MakeDirectoryResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the remove_directory REST call
#
@@ -1035,20 +1097,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "remove_directory",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the move_directory REST call
#
@@ -1073,20 +1137,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "move_directory",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::MoveDirectoryResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the read_file REST call
#
@@ -1111,20 +1177,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "read_file",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ReadFileResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the remove_file REST call
#
@@ -1149,20 +1217,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "remove_file",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the move_file REST call
#
@@ -1187,20 +1257,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "move_file",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::MoveFileResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the write_file REST call
#
@@ -1225,20 +1297,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "write_file",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::WriteFileResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the list_release_configs REST call
#
@@ -1263,20 +1337,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "list_release_configs",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ListReleaseConfigsResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the get_release_config REST call
#
@@ -1301,20 +1377,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "get_release_config",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ReleaseConfig.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the create_release_config REST call
#
@@ -1339,20 +1417,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "create_release_config",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ReleaseConfig.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the update_release_config REST call
#
@@ -1377,20 +1457,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "update_release_config",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ReleaseConfig.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the delete_release_config REST call
#
@@ -1415,20 +1497,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "delete_release_config",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the list_compilation_results REST call
#
@@ -1453,20 +1537,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "list_compilation_results",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ListCompilationResultsResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the get_compilation_result REST call
#
@@ -1491,20 +1577,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "get_compilation_result",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::CompilationResult.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the create_compilation_result REST call
#
@@ -1529,20 +1617,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "create_compilation_result",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::CompilationResult.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the query_compilation_result_actions REST call
#
@@ -1567,20 +1657,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "query_compilation_result_actions",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::QueryCompilationResultActionsResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the list_workflow_configs REST call
#
@@ -1605,20 +1697,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "list_workflow_configs",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ListWorkflowConfigsResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the get_workflow_config REST call
#
@@ -1643,20 +1737,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "get_workflow_config",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::WorkflowConfig.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the create_workflow_config REST call
#
@@ -1681,20 +1777,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "create_workflow_config",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::WorkflowConfig.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the update_workflow_config REST call
#
@@ -1719,20 +1817,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "update_workflow_config",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::WorkflowConfig.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the delete_workflow_config REST call
#
@@ -1757,20 +1857,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "delete_workflow_config",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the list_workflow_invocations REST call
#
@@ -1795,20 +1897,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "list_workflow_invocations",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::ListWorkflowInvocationsResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the get_workflow_invocation REST call
#
@@ -1833,20 +1937,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "get_workflow_invocation",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::WorkflowInvocation.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the create_workflow_invocation REST call
#
@@ -1871,20 +1977,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "create_workflow_invocation",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::WorkflowInvocation.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the delete_workflow_invocation REST call
#
@@ -1909,20 +2017,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "delete_workflow_invocation",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the cancel_workflow_invocation REST call
#
@@ -1947,20 +2057,22 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "cancel_workflow_invocation",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Protobuf::Empty.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# Baseline implementation for the query_workflow_invocation_actions REST call
#
@@ -1985,19 +2097,21 @@
{}
end
response = @client_stub.make_http_request(
verb,
- uri: uri,
- body: body || "",
- params: query_string_params,
+ uri: uri,
+ body: body || "",
+ params: query_string_params,
+ method_name: "query_workflow_invocation_actions",
options: options
)
operation = ::Gapic::Rest::TransportOperation.new response
result = ::Google::Cloud::Dataform::V1beta1::QueryWorkflowInvocationActionsResponse.decode_json response.body, ignore_unknown_fields: true
-
- yield result, operation if block_given?
- result
+ catch :response do
+ yield result, operation if block_given?
+ result
+ end
end
##
# @private
#