Api-roll 42: 2016-11-08

generated/googleapis_beta/lib/dataflow/v1b3.dart

 // This is a generated file (see the discoveryapis_generator project).
 
 library googleapis_beta.dataflow.v1b3;
 
 import 'dart:core' as core;
 import 'dart:async' as async;
 import 'dart:convert' as convert;
 
 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons;
 import 'package:http/http.dart' as http;
@@ skipping 21 matching lines @@
 
   DataflowApi(http.Client client, {core.String rootUrl: "https://dataflow.googleapis.com/", core.String servicePath: ""}) :
       _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_AGENT);
 }
 
 
 class ProjectsResourceApi {
   final commons.ApiRequester _requester;
 
   ProjectsJobsResourceApi get jobs => new ProjectsJobsResourceApi(_requester);
+  ProjectsLocationsResourceApi get locations => new ProjectsLocationsResourceApi(_requester);
   ProjectsTemplatesResourceApi get templates => new ProjectsTemplatesResourceApi(_requester);
 
   ProjectsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
    * Send a worker_message to the service.
    *
    * [request] - The metadata request object.
    *
@@ skipping 59 matching lines @@
    * [projectId] - The project which owns the job.
    *
    * [view] - Level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    *
    * [replaceJobId] - DEPRECATED. This field is now on the Job message.
    *
+   * [location] - The location which contains this job.
+   *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<Job> create(Job request, core.String projectId, {core.String view, core.String replaceJobId, core.String location}) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (view != null) {
+      _queryParams["view"] = [view];
+    }
+    if (replaceJobId != null) {
+      _queryParams["replaceJobId"] = [replaceJobId];
+    }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new Job.fromJson(data));
+  }
+
+  /**
+   * Gets the state of the specified dataflow job.
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project which owns the job.
+   *
+   * [jobId] - Identifies a single job.
+   *
+   * [view] - Level of information requested in response.
+   * Possible string values are:
+   * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
+   * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
+   * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
+   *
+   * [location] - The location which contains this job.
+   *
+   * Completes with a [Job].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<Job> get(core.String projectId, core.String jobId, {core.String view, core.String location}) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (jobId == null) {
+      throw new core.ArgumentError("Parameter jobId is required.");
+    }
+    if (view != null) {
+      _queryParams["view"] = [view];
+    }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
+
+    var _response = _requester.request(_url,
+                                       "GET",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new Job.fromJson(data));
+  }
+
+  /**
+   * Request the job status.
+   *
+   * Request parameters:
+   *
+   * [projectId] - A project id.
+   *
+   * [jobId] - The job to get messages for.
+   *
+   * [startTime] - Return only metric data that has changed since this time.
+   * Default is to return all information about all metrics for the job.
+   *
+   * [location] - The location which contains the job specified by job_id.
+   *
+   * Completes with a [JobMetrics].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<JobMetrics> getMetrics(core.String projectId, core.String jobId, {core.String startTime, core.String location}) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (jobId == null) {
+      throw new core.ArgumentError("Parameter jobId is required.");
+    }
+    if (startTime != null) {
+      _queryParams["startTime"] = [startTime];
+    }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/metrics';
+
+    var _response = _requester.request(_url,
+                                       "GET",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new JobMetrics.fromJson(data));
+  }
+
+  /**
+   * List the jobs of a project
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project which owns the jobs.
+   *
+   * [filter] - The kind of filter to use.
+   * Possible string values are:
+   * - "UNKNOWN" : A UNKNOWN.
+   * - "ALL" : A ALL.
+   * - "TERMINATED" : A TERMINATED.
+   * - "ACTIVE" : A ACTIVE.
+   *
+   * [view] - Level of information requested in response. Default is SUMMARY.
+   * Possible string values are:
+   * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
+   * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
+   * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
+   *
+   * [pageSize] - If there are many jobs, limit response to at most this many.
+   * The actual number of jobs returned will be the lesser of max_responses and
+   * an unspecified server-defined limit.
+   *
+   * [pageToken] - Set this to the 'next_page_token' field of a previous
+   * response to request additional results in a long list.
+   *
+   * [location] - The location which contains this job.
+   *
+   * Completes with a [ListJobsResponse].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<ListJobsResponse> list(core.String projectId, {core.String filter, core.String view, core.int pageSize, core.String pageToken, core.String location}) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (filter != null) {
+      _queryParams["filter"] = [filter];
+    }
+    if (view != null) {
+      _queryParams["view"] = [view];
+    }
+    if (pageSize != null) {
+      _queryParams["pageSize"] = ["${pageSize}"];
+    }
+    if (pageToken != null) {
+      _queryParams["pageToken"] = [pageToken];
+    }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs';
+
+    var _response = _requester.request(_url,
+                                       "GET",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new ListJobsResponse.fromJson(data));
+  }
+
+  /**
+   * Updates the state of an existing dataflow job.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project which owns the job.
+   *
+   * [jobId] - Identifies a single job.
+   *
+   * [location] - The location which contains this job.
+   *
+   * Completes with a [Job].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<Job> update(Job request, core.String projectId, core.String jobId, {core.String location}) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (jobId == null) {
+      throw new core.ArgumentError("Parameter jobId is required.");
+    }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
+
+    var _response = _requester.request(_url,
+                                       "PUT",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new Job.fromJson(data));
+  }
+
+}
+
+
+class ProjectsJobsDebugResourceApi {
+  final commons.ApiRequester _requester;
+
+  ProjectsJobsDebugResourceApi(commons.ApiRequester client) : 
+      _requester = client;
+
+  /**
+   * Get encoded debug configuration for component. Not cacheable.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project id.
+   *
+   * [jobId] - The job id.
+   *
+   * Completes with a [GetDebugConfigResponse].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<GetDebugConfigResponse> getConfig(GetDebugConfigRequest request, core.String projectId, core.String jobId) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (jobId == null) {
+      throw new core.ArgumentError("Parameter jobId is required.");
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/debug/getConfig';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new GetDebugConfigResponse.fromJson(data));
+  }
+
+  /**
+   * Send encoded debug capture data for component.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project id.
+   *
+   * [jobId] - The job id.
+   *
+   * Completes with a [SendDebugCaptureResponse].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<SendDebugCaptureResponse> sendCapture(SendDebugCaptureRequest request, core.String projectId, core.String jobId) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (jobId == null) {
+      throw new core.ArgumentError("Parameter jobId is required.");
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/debug/sendCapture';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new SendDebugCaptureResponse.fromJson(data));
+  }
+
+}
+
+
+class ProjectsJobsMessagesResourceApi {
+  final commons.ApiRequester _requester;
+
+  ProjectsJobsMessagesResourceApi(commons.ApiRequester client) : 
+      _requester = client;
+
+  /**
+   * Request the job status.
+   *
+   * Request parameters:
+   *
+   * [projectId] - A project id.
+   *
+   * [jobId] - The job to get messages about.
+   *
+   * [minimumImportance] - Filter to only get messages with importance >= level
+   * Possible string values are:
+   * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN.
+   * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG.
+   * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED.
+   * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC.
+   * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING.
+   * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR.
+   *
+   * [pageSize] - If specified, determines the maximum number of messages to
+   * return. If unspecified, the service may choose an appropriate default, or
+   * may return an arbitrarily large number of results.
+   *
+   * [pageToken] - If supplied, this should be the value of next_page_token
+   * returned by an earlier call. This will cause the next page of results to be
+   * returned.
+   *
+   * [startTime] - If specified, return only messages with timestamps >=
+   * start_time. The default is the job creation time (i.e. beginning of
+   * messages).
+   *
+   * [endTime] - Return only messages with timestamps < end_time. The default is
+   * now (i.e. return up to the latest messages available).
+   *
+   * [location] - The location which contains the job specified by job_id.
+   *
+   * Completes with a [ListJobMessagesResponse].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<ListJobMessagesResponse> list(core.String projectId, core.String jobId, {core.String minimumImportance, core.int pageSize, core.String pageToken, core.String startTime, core.String endTime, core.String location}) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (jobId == null) {
+      throw new core.ArgumentError("Parameter jobId is required.");
+    }
+    if (minimumImportance != null) {
+      _queryParams["minimumImportance"] = [minimumImportance];
+    }
+    if (pageSize != null) {
+      _queryParams["pageSize"] = ["${pageSize}"];
+    }
+    if (pageToken != null) {
+      _queryParams["pageToken"] = [pageToken];
+    }
+    if (startTime != null) {
+      _queryParams["startTime"] = [startTime];
+    }
+    if (endTime != null) {
+      _queryParams["endTime"] = [endTime];
+    }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages';
+
+    var _response = _requester.request(_url,
+                                       "GET",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new ListJobMessagesResponse.fromJson(data));
+  }
+
+}
+
+
+class ProjectsJobsWorkItemsResourceApi {
+  final commons.ApiRequester _requester;
+
+  ProjectsJobsWorkItemsResourceApi(commons.ApiRequester client) : 
+      _requester = client;
+
+  /**
+   * Leases a dataflow WorkItem to run.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - Identifies the project this worker belongs to.
+   *
+   * [jobId] - Identifies the workflow job this worker belongs to.
+   *
+   * Completes with a [LeaseWorkItemResponse].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<LeaseWorkItemResponse> lease(LeaseWorkItemRequest request, core.String projectId, core.String jobId) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (jobId == null) {
+      throw new core.ArgumentError("Parameter jobId is required.");
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/workItems:lease';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new LeaseWorkItemResponse.fromJson(data));
+  }
+
+  /**
+   * Reports the status of dataflow WorkItems leased by a worker.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project which owns the WorkItem's job.
+   *
+   * [jobId] - The job which the WorkItem is part of.
+   *
+   * Completes with a [ReportWorkItemStatusResponse].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
+   * error.
+   *
+   * If the used [http.Client] completes with an error when making a REST call,
+   * this method will complete with the same error.
+   */
+  async.Future<ReportWorkItemStatusResponse> reportStatus(ReportWorkItemStatusRequest request, core.String projectId, core.String jobId) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (projectId == null) {
+      throw new core.ArgumentError("Parameter projectId is required.");
+    }
+    if (jobId == null) {
+      throw new core.ArgumentError("Parameter jobId is required.");
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/workItems:reportStatus';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new ReportWorkItemStatusResponse.fromJson(data));
+  }
+
+}
+
+
+class ProjectsLocationsResourceApi {
+  final commons.ApiRequester _requester;
+
+  ProjectsLocationsJobsResourceApi get jobs => new ProjectsLocationsJobsResourceApi(_requester);
+
+  ProjectsLocationsResourceApi(commons.ApiRequester client) : 
+      _requester = client;
+}
+
+
+class ProjectsLocationsJobsResourceApi {
+  final commons.ApiRequester _requester;
+
+  ProjectsLocationsJobsMessagesResourceApi get messages => new ProjectsLocationsJobsMessagesResourceApi(_requester);
+  ProjectsLocationsJobsWorkItemsResourceApi get workItems => new ProjectsLocationsJobsWorkItemsResourceApi(_requester);
+
+  ProjectsLocationsJobsResourceApi(commons.ApiRequester client) : 
+      _requester = client;
+
+  /**
+   * Creates a dataflow job.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project which owns the job.
+   *
+   * [location] - The location which contains this job.
+   *
+   * [view] - Level of information requested in response.
+   * Possible string values are:
+   * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
+   * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
+   * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
+   *
+   * [replaceJobId] - DEPRECATED. This field is now on the Job message.
+   *
+   * Completes with a [Job].
+   *
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<Job> create(Job request, core.String projectId, {core.String view, core.String replaceJobId}) {
+  async.Future<Job> create(Job request, core.String projectId, core.String location, {core.String view, core.String replaceJobId}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
+    if (location == null) {
+      throw new core.ArgumentError("Parameter location is required.");
+    }
     if (view != null) {
       _queryParams["view"] = [view];
     }
     if (replaceJobId != null) {
       _queryParams["replaceJobId"] = [replaceJobId];
     }
 
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs';
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
   /**
    * Gets the state of the specified dataflow job.
    *
    * Request parameters:
    *
    * [projectId] - The project which owns the job.
    *
+   * [location] - The location which contains this job.
+   *
    * [jobId] - Identifies a single job.
    *
    * [view] - Level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<Job> get(core.String projectId, core.String jobId, {core.String view}) {
+  async.Future<Job> get(core.String projectId, core.String location, core.String jobId, {core.String view}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
+    if (location == null) {
+      throw new core.ArgumentError("Parameter location is required.");
+    }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
     if (view != null) {
       _queryParams["view"] = [view];
     }
 
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
   /**
    * Request the job status.
    *
    * Request parameters:
    *
    * [projectId] - A project id.
    *
+   * [location] - The location which contains the job specified by job_id.
+   *
    * [jobId] - The job to get messages for.
    *
    * [startTime] - Return only metric data that has changed since this time.
    * Default is to return all information about all metrics for the job.
    *
    * Completes with a [JobMetrics].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<JobMetrics> getMetrics(core.String projectId, core.String jobId, {core.String startTime}) {
+  async.Future<JobMetrics> getMetrics(core.String projectId, core.String location, core.String jobId, {core.String startTime}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
+    if (location == null) {
+      throw new core.ArgumentError("Parameter location is required.");
+    }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
     if (startTime != null) {
       _queryParams["startTime"] = [startTime];
     }
 
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/metrics';
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/metrics';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new JobMetrics.fromJson(data));
   }
 
   /**
    * List the jobs of a project
    *
    * Request parameters:
    *
    * [projectId] - The project which owns the jobs.
    *
+   * [location] - The location which contains this job.
+   *
    * [filter] - The kind of filter to use.
    * Possible string values are:
    * - "UNKNOWN" : A UNKNOWN.
    * - "ALL" : A ALL.
    * - "TERMINATED" : A TERMINATED.
    * - "ACTIVE" : A ACTIVE.
    *
    * [view] - Level of information requested in response. Default is SUMMARY.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    *
    * [pageSize] - If there are many jobs, limit response to at most this many.
    * The actual number of jobs returned will be the lesser of max_responses and
    * an unspecified server-defined limit.
    *
    * [pageToken] - Set this to the 'next_page_token' field of a previous
    * response to request additional results in a long list.
    *
    * Completes with a [ListJobsResponse].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<ListJobsResponse> list(core.String projectId, {core.String filter, core.String view, core.int pageSize, core.String pageToken}) {
+  async.Future<ListJobsResponse> list(core.String projectId, core.String location, {core.String filter, core.String view, core.int pageSize, core.String pageToken}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
+    if (location == null) {
+      throw new core.ArgumentError("Parameter location is required.");
+    }
     if (filter != null) {
       _queryParams["filter"] = [filter];
     }
     if (view != null) {
       _queryParams["view"] = [view];
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
 
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs';
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new ListJobsResponse.fromJson(data));
   }
 
   /**
    * Updates the state of an existing dataflow job.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - The project which owns the job.
    *
+   * [location] - The location which contains this job.
+   *
    * [jobId] - Identifies a single job.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<Job> update(Job request, core.String projectId, core.String jobId) {
+  async.Future<Job> update(Job request, core.String projectId, core.String location, core.String jobId) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
+    if (location == null) {
+      throw new core.ArgumentError("Parameter location is required.");
+    }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
 
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
 
     var _response = _requester.request(_url,
                                        "PUT",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
 }
 
 
-class ProjectsJobsDebugResourceApi {
+class ProjectsLocationsJobsMessagesResourceApi {
   final commons.ApiRequester _requester;
 
-  ProjectsJobsDebugResourceApi(commons.ApiRequester client) : 
+  ProjectsLocationsJobsMessagesResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
-   * Get encoded debug configuration for component. Not cacheable.
-   *
-   * [request] - The metadata request object.
-   *
-   * Request parameters:
-   *
-   * [projectId] - The project id.
-   *
-   * [jobId] - The job id.
-   *
-   * Completes with a [GetDebugConfigResponse].
-   *
-   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
-   * error.
-   *
-   * If the used [http.Client] completes with an error when making a REST call,
-   * this method will complete with the same error.
-   */
-  async.Future<GetDebugConfigResponse> getConfig(GetDebugConfigRequest request, core.String projectId, core.String jobId) {
-    var _url = null;
-    var _queryParams = new core.Map();
-    var _uploadMedia = null;
-    var _uploadOptions = null;
-    var _downloadOptions = commons.DownloadOptions.Metadata;
-    var _body = null;
-
-    if (request != null) {
-      _body = convert.JSON.encode((request).toJson());
-    }
-    if (projectId == null) {
-      throw new core.ArgumentError("Parameter projectId is required.");
-    }
-    if (jobId == null) {
-      throw new core.ArgumentError("Parameter jobId is required.");
-    }
-
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/debug/getConfig';
-
-    var _response = _requester.request(_url,
-                                       "POST",
-                                       body: _body,
-                                       queryParams: _queryParams,
-                                       uploadOptions: _uploadOptions,
-                                       uploadMedia: _uploadMedia,
-                                       downloadOptions: _downloadOptions);
-    return _response.then((data) => new GetDebugConfigResponse.fromJson(data));
-  }
-
-  /**
-   * Send encoded debug capture data for component.
-   *
-   * [request] - The metadata request object.
-   *
-   * Request parameters:
-   *
-   * [projectId] - The project id.
-   *
-   * [jobId] - The job id.
-   *
-   * Completes with a [SendDebugCaptureResponse].
-   *
-   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
-   * error.
-   *
-   * If the used [http.Client] completes with an error when making a REST call,
-   * this method will complete with the same error.
-   */
-  async.Future<SendDebugCaptureResponse> sendCapture(SendDebugCaptureRequest request, core.String projectId, core.String jobId) {
-    var _url = null;
-    var _queryParams = new core.Map();
-    var _uploadMedia = null;
-    var _uploadOptions = null;
-    var _downloadOptions = commons.DownloadOptions.Metadata;
-    var _body = null;
-
-    if (request != null) {
-      _body = convert.JSON.encode((request).toJson());
-    }
-    if (projectId == null) {
-      throw new core.ArgumentError("Parameter projectId is required.");
-    }
-    if (jobId == null) {
-      throw new core.ArgumentError("Parameter jobId is required.");
-    }
-
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/debug/sendCapture';
-
-    var _response = _requester.request(_url,
-                                       "POST",
-                                       body: _body,
-                                       queryParams: _queryParams,
-                                       uploadOptions: _uploadOptions,
-                                       uploadMedia: _uploadMedia,
-                                       downloadOptions: _downloadOptions);
-    return _response.then((data) => new SendDebugCaptureResponse.fromJson(data));
-  }
-
-}
-
-
-class ProjectsJobsMessagesResourceApi {
-  final commons.ApiRequester _requester;
-
-  ProjectsJobsMessagesResourceApi(commons.ApiRequester client) : 
-      _requester = client;
-
-  /**
    * Request the job status.
    *
    * Request parameters:
    *
    * [projectId] - A project id.
    *
+   * [location] - The location which contains the job specified by job_id.
+   *
    * [jobId] - The job to get messages about.
    *
    * [minimumImportance] - Filter to only get messages with importance >= level
    * Possible string values are:
    * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN.
    * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG.
    * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED.
    * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC.
    * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING.
    * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR.
@@ skipping 14 matching lines @@
    * now (i.e. return up to the latest messages available).
    *
    * Completes with a [ListJobMessagesResponse].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<ListJobMessagesResponse> list(core.String projectId, core.String jobId, {core.String minimumImportance, core.int pageSize, core.String pageToken, core.String startTime, core.String endTime}) {
+  async.Future<ListJobMessagesResponse> list(core.String projectId, core.String location, core.String jobId, {core.String minimumImportance, core.int pageSize, core.String pageToken, core.String startTime, core.String endTime}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
+    if (location == null) {
+      throw new core.ArgumentError("Parameter location is required.");
+    }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
     if (minimumImportance != null) {
       _queryParams["minimumImportance"] = [minimumImportance];
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (startTime != null) {
       _queryParams["startTime"] = [startTime];
     }
     if (endTime != null) {
       _queryParams["endTime"] = [endTime];
     }
 
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages';
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new ListJobMessagesResponse.fromJson(data));
   }
 
 }
 
 
-class ProjectsJobsWorkItemsResourceApi {
+class ProjectsLocationsJobsWorkItemsResourceApi {
   final commons.ApiRequester _requester;
 
-  ProjectsJobsWorkItemsResourceApi(commons.ApiRequester client) : 
+  ProjectsLocationsJobsWorkItemsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
    * Leases a dataflow WorkItem to run.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - Identifies the project this worker belongs to.
    *
+   * [location] - The location which contains the WorkItem's job.
+   *
    * [jobId] - Identifies the workflow job this worker belongs to.
    *
    * Completes with a [LeaseWorkItemResponse].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<LeaseWorkItemResponse> lease(LeaseWorkItemRequest request, core.String projectId, core.String jobId) {
+  async.Future<LeaseWorkItemResponse> lease(LeaseWorkItemRequest request, core.String projectId, core.String location, core.String jobId) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
+    if (location == null) {
+      throw new core.ArgumentError("Parameter location is required.");
+    }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
 
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/workItems:lease';
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/workItems:lease';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new LeaseWorkItemResponse.fromJson(data));
   }
 
   /**
    * Reports the status of dataflow WorkItems leased by a worker.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - The project which owns the WorkItem's job.
    *
+   * [location] - The location which contains the WorkItem's job.
+   *
    * [jobId] - The job which the WorkItem is part of.
    *
    * Completes with a [ReportWorkItemStatusResponse].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<ReportWorkItemStatusResponse> reportStatus(ReportWorkItemStatusRequest request, core.String projectId, core.String jobId) {
+  async.Future<ReportWorkItemStatusResponse> reportStatus(ReportWorkItemStatusRequest request, core.String projectId, core.String location, core.String jobId) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
+    if (location == null) {
+      throw new core.ArgumentError("Parameter location is required.");
+    }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
 
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/workItems:reportStatus';
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/workItems:reportStatus';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new ReportWorkItemStatusResponse.fromJson(data));
   }
@@ skipping 933 matching lines @@
   core.Map<core.String, core.Object> internalExperiments;
   /**
    * The Dataflow SDK pipeline options specified by the user. These options are
    * passed through the service and are used to recreate the SDK pipeline
    * options on the worker in a language agnostic and platform independent way.
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> sdkPipelineOptions;
+  /** Identity to run virtual machines as. Defaults to the default account. */
+  core.String serviceAccountEmail;
   /**
    * The prefix of the resources the system should use for temporary storage.
    * The system will append the suffix "/temp-{JOBNAME} to this resource prefix,
    * where {JOBNAME} is the value of the job_name field. The resulting bucket
    * and object prefix is used as the prefix of the resources used to store
    * temporary data needed during the job execution. NOTE: This will override
    * the value in taskrunner_settings. The supported resource type is: Google
    * Cloud Storage: storage.googleapis.com/{bucket}/{object}
    * bucket.storage.googleapis.com/{object}
    */
@@ skipping 30 matching lines @@
     }
     if (_json.containsKey("experiments")) {
       experiments = _json["experiments"];
     }
     if (_json.containsKey("internalExperiments")) {
       internalExperiments = _json["internalExperiments"];
     }
     if (_json.containsKey("sdkPipelineOptions")) {
       sdkPipelineOptions = _json["sdkPipelineOptions"];
     }
+    if (_json.containsKey("serviceAccountEmail")) {
+      serviceAccountEmail = _json["serviceAccountEmail"];
+    }
     if (_json.containsKey("tempStoragePrefix")) {
       tempStoragePrefix = _json["tempStoragePrefix"];
     }
     if (_json.containsKey("userAgent")) {
       userAgent = _json["userAgent"];
     }
     if (_json.containsKey("version")) {
       version = _json["version"];
     }
     if (_json.containsKey("workerPools")) {
@@ skipping 11 matching lines @@
     }
     if (experiments != null) {
       _json["experiments"] = experiments;
     }
     if (internalExperiments != null) {
       _json["internalExperiments"] = internalExperiments;
     }
     if (sdkPipelineOptions != null) {
       _json["sdkPipelineOptions"] = sdkPipelineOptions;
     }
+    if (serviceAccountEmail != null) {
+      _json["serviceAccountEmail"] = serviceAccountEmail;
+    }
     if (tempStoragePrefix != null) {
       _json["tempStoragePrefix"] = tempStoragePrefix;
     }
     if (userAgent != null) {
       _json["userAgent"] = userAgent;
     }
     if (version != null) {
       _json["version"] = version;
     }
     if (workerPools != null) {
       _json["workerPools"] = workerPools.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 /**
+ * FailedLocation indicates which location failed to respond to a request for
+ * data.
+ */
+class FailedLocation {
+  /** The name of the failed location. */
+  core.String name;
+
+  FailedLocation();
+
+  FailedLocation.fromJson(core.Map _json) {
+    if (_json.containsKey("name")) {
+      name = _json["name"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (name != null) {
+      _json["name"] = name;
+    }
+    return _json;
+  }
+}
+
+/**
  * An instruction that copies its inputs (zero or more) to its (single) output.
  */
 class FlattenInstruction {
   /** Describes the inputs to the flatten instruction. */
   core.List<InstructionInput> inputs;
 
   FlattenInstruction();
 
   FlattenInstruction.fromJson(core.Map _json) {
     if (_json.containsKey("inputs")) {
@@ skipping 326 matching lines @@
    */
   core.String id;
   /**
    * User-defined labels for this job. The labels map can contain no more than
    * 64 entries. Entries of the labels map are UTF8 strings that comply with the
    * following restrictions: * Keys must conform to regexp: \p{Ll}\p{Lo}{0,62} *
    * Values must conform to regexp: [\p{Ll}\p{Lo}\p{N}_-]{0,63} * Both keys and
    * values are additionally constrained to be <= 128 bytes in size.
    */
   core.Map<core.String, core.String> labels;
+  /** The location which contains this job. */
+  core.String location;
   /**
    * The user-specified Dataflow job name. Only one Job with a given name may
    * exist in a project at any given time. If a caller attempts to create a Job
    * with the same name as an already-existing Job, the attempt will return the
    * existing Job. The name must match the regular expression
    * [a-z]([-a-z0-9]{0,38}[a-z0-9])?
    */
   core.String name;
   /** The project which owns the job. */
   core.String projectId;
@@ skipping 71 matching lines @@
     }
     if (_json.containsKey("executionInfo")) {
       executionInfo = new JobExecutionInfo.fromJson(_json["executionInfo"]);
     }
     if (_json.containsKey("id")) {
       id = _json["id"];
     }
     if (_json.containsKey("labels")) {
       labels = _json["labels"];
     }
+    if (_json.containsKey("location")) {
+      location = _json["location"];
+    }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
     if (_json.containsKey("projectId")) {
       projectId = _json["projectId"];
     }
     if (_json.containsKey("replaceJobId")) {
       replaceJobId = _json["replaceJobId"];
     }
     if (_json.containsKey("replacedByJobId")) {
@@ skipping 35 matching lines @@
     }
     if (executionInfo != null) {
       _json["executionInfo"] = (executionInfo).toJson();
     }
     if (id != null) {
       _json["id"] = id;
     }
     if (labels != null) {
       _json["labels"] = labels;
     }
+    if (location != null) {
+      _json["location"] = location;
+    }
     if (name != null) {
       _json["name"] = name;
     }
     if (projectId != null) {
       _json["projectId"] = projectId;
     }
     if (replaceJobId != null) {
       _json["replaceJobId"] = replaceJobId;
     }
     if (replacedByJobId != null) {
@@ skipping 278 matching lines @@
       _json["start"] = start;
     }
     return _json;
   }
 }
 
 /** Request to lease WorkItems. */
 class LeaseWorkItemRequest {
   /** The current timestamp at the worker. */
   core.String currentWorkerTime;
+  /** The location which contains the WorkItem's job. */
+  core.String location;
   /** The initial lease period. */
   core.String requestedLeaseDuration;
   /** Filter for WorkItem type. */
   core.List<core.String> workItemTypes;
   /**
    * Worker capabilities. WorkItems might be limited to workers with specific
    * capabilities.
    */
   core.List<core.String> workerCapabilities;
   /**
    * Identifies the worker leasing work -- typically the ID of the virtual
    * machine running the worker.
    */
   core.String workerId;
 
   LeaseWorkItemRequest();
 
   LeaseWorkItemRequest.fromJson(core.Map _json) {
     if (_json.containsKey("currentWorkerTime")) {
       currentWorkerTime = _json["currentWorkerTime"];
     }
+    if (_json.containsKey("location")) {
+      location = _json["location"];
+    }
     if (_json.containsKey("requestedLeaseDuration")) {
       requestedLeaseDuration = _json["requestedLeaseDuration"];
     }
     if (_json.containsKey("workItemTypes")) {
       workItemTypes = _json["workItemTypes"];
     }
     if (_json.containsKey("workerCapabilities")) {
       workerCapabilities = _json["workerCapabilities"];
     }
     if (_json.containsKey("workerId")) {
       workerId = _json["workerId"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (currentWorkerTime != null) {
       _json["currentWorkerTime"] = currentWorkerTime;
     }
+    if (location != null) {
+      _json["location"] = location;
+    }
     if (requestedLeaseDuration != null) {
       _json["requestedLeaseDuration"] = requestedLeaseDuration;
     }
     if (workItemTypes != null) {
       _json["workItemTypes"] = workItemTypes;
     }
     if (workerCapabilities != null) {
       _json["workerCapabilities"] = workerCapabilities;
     }
     if (workerId != null) {
@@ skipping 53 matching lines @@
     }
     return _json;
   }
 }
 
 /**
  * Response to a request to list Dataflow jobs. This may be a partial response,
  * depending on the page size in the ListJobsRequest.
  */
 class ListJobsResponse {
+  /** Zero or more messages describing locations that failed to respond. */
+  core.List<FailedLocation> failedLocation;
   /** A subset of the requested job information. */
   core.List<Job> jobs;
   /** Set if there may be more results than fit in this response. */
   core.String nextPageToken;
 
   ListJobsResponse();
 
   ListJobsResponse.fromJson(core.Map _json) {
+    if (_json.containsKey("failedLocation")) {
+      failedLocation = _json["failedLocation"].map((value) => new FailedLocation.fromJson(value)).toList();
+    }
     if (_json.containsKey("jobs")) {
       jobs = _json["jobs"].map((value) => new Job.fromJson(value)).toList();
     }
     if (_json.containsKey("nextPageToken")) {
       nextPageToken = _json["nextPageToken"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (failedLocation != null) {
+      _json["failedLocation"] = failedLocation.map((value) => (value).toJson()).toList();
+    }
     if (jobs != null) {
       _json["jobs"] = jobs.map((value) => (value).toJson()).toList();
     }
     if (nextPageToken != null) {
       _json["nextPageToken"] = nextPageToken;
     }
     return _json;
   }
 }
 
@@ skipping 796 matching lines @@
       _json["source"] = (source).toJson();
     }
     return _json;
   }
 }
 
 /** Request to report the status of WorkItems. */
 class ReportWorkItemStatusRequest {
   /** The current timestamp at the worker. */
   core.String currentWorkerTime;
+  /** The location which contains the WorkItem's job. */
+  core.String location;
   /**
    * The order is unimportant, except that the order of the WorkItemServiceState
    * messages in the ReportWorkItemStatusResponse corresponds to the order of
    * WorkItemStatus messages here.
    */
   core.List<WorkItemStatus> workItemStatuses;
   /**
    * The ID of the worker reporting the WorkItem status. If this does not match
    * the ID of the worker which the Dataflow service believes currently has the
    * lease on the WorkItem, the report will be dropped (with an error response).
    */
   core.String workerId;
 
   ReportWorkItemStatusRequest();
 
   ReportWorkItemStatusRequest.fromJson(core.Map _json) {
     if (_json.containsKey("currentWorkerTime")) {
       currentWorkerTime = _json["currentWorkerTime"];
     }
+    if (_json.containsKey("location")) {
+      location = _json["location"];
+    }
     if (_json.containsKey("workItemStatuses")) {
       workItemStatuses = _json["workItemStatuses"].map((value) => new WorkItemStatus.fromJson(value)).toList();
     }
     if (_json.containsKey("workerId")) {
       workerId = _json["workerId"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (currentWorkerTime != null) {
       _json["currentWorkerTime"] = currentWorkerTime;
     }
+    if (location != null) {
+      _json["location"] = location;
+    }
     if (workItemStatuses != null) {
       _json["workItemStatuses"] = workItemStatuses.map((value) => (value).toJson()).toList();
     }
     if (workerId != null) {
       _json["workerId"] = workerId;
     }
     return _json;
   }
 }
 
@@ skipping 2638 matching lines @@
     var _json = new core.Map();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     return _json;
   }
 }