lib/google/cloud/dataflow/v1beta3/templates_service/client.rb in google-cloud-dataflow-v1beta3-0.1.4 vs lib/google/cloud/dataflow/v1beta3/templates_service/client.rb in google-cloud-dataflow-v1beta3-0.2.0

@@ -217,10 +217,18 @@
               metadata[:"x-goog-api-client"] ||= ::Gapic::Headers.x_goog_api_client \
                 lib_name: @config.lib_name, lib_version: @config.lib_version,
                 gapic_version: ::Google::Cloud::Dataflow::V1beta3::VERSION
               metadata[:"x-goog-user-project"] = @quota_project_id if @quota_project_id
 
+              header_params = {}
+              if request.project_id
+                header_params["project_id"] = request.project_id
+              end
+
+              request_params_header = header_params.map { |k, v| "#{k}=#{v}" }.join("&")
+              metadata[:"x-goog-request-params"] ||= request_params_header
+
               options.apply_defaults timeout:      @config.rpcs.create_job_from_template.timeout,
                                      metadata:     metadata,
                                      retry_policy: @config.rpcs.create_job_from_template.retry_policy
 
               options.apply_defaults timeout:      @config.timeout,
@@ -310,10 +318,18 @@
               metadata[:"x-goog-api-client"] ||= ::Gapic::Headers.x_goog_api_client \
                 lib_name: @config.lib_name, lib_version: @config.lib_version,
                 gapic_version: ::Google::Cloud::Dataflow::V1beta3::VERSION
               metadata[:"x-goog-user-project"] = @quota_project_id if @quota_project_id
 
+              header_params = {}
+              if request.project_id
+                header_params["project_id"] = request.project_id
+              end
+
+              request_params_header = header_params.map { |k, v| "#{k}=#{v}" }.join("&")
+              metadata[:"x-goog-request-params"] ||= request_params_header
+
               options.apply_defaults timeout:      @config.rpcs.launch_template.timeout,
                                      metadata:     metadata,
                                      retry_policy: @config.rpcs.launch_template.retry_policy
 
               options.apply_defaults timeout:      @config.timeout,
@@ -396,9 +412,17 @@
               # Set x-goog-api-client and x-goog-user-project headers
               metadata[:"x-goog-api-client"] ||= ::Gapic::Headers.x_goog_api_client \
                 lib_name: @config.lib_name, lib_version: @config.lib_version,
                 gapic_version: ::Google::Cloud::Dataflow::V1beta3::VERSION
               metadata[:"x-goog-user-project"] = @quota_project_id if @quota_project_id
+
+              header_params = {}
+              if request.project_id
+                header_params["project_id"] = request.project_id
+              end
+
+              request_params_header = header_params.map { |k, v| "#{k}=#{v}" }.join("&")
+              metadata[:"x-goog-request-params"] ||= request_params_header
 
               options.apply_defaults timeout:      @config.rpcs.get_template.timeout,
                                      metadata:     metadata,
                                      retry_policy: @config.rpcs.get_template.retry_policy