Api-roll 48: 2017-04-18

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;
 
 export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' show
     ApiRequestError, DetailedApiRequestError;
 
 const core.String USER_AGENT = 'dart-api-client dataflow/v1b3';
 
 /** Manages Google Cloud Dataflow projects on Google Cloud Platform. */
 class DataflowApi {
   /** View and manage your data across Google Cloud Platform services */
   static const CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform";
 
+  /** View and manage your Google Compute Engine resources */
+  static const ComputeScope = "https://www.googleapis.com/auth/compute";
+
   /** View your email address */
   static const UserinfoEmailScope = "https://www.googleapis.com/auth/userinfo.email";
 
 
   final commons.ApiRequester _requester;
 
   ProjectsResourceApi get projects => new ProjectsResourceApi(_requester);
 
   DataflowApi(http.Client client, {core.String rootUrl: "https://dataflow.googleapis.com/", core.String servicePath: ""}) :
       _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_AGENT);
@@ skipping 69 matching lines @@
 
   /**
    * Creates a Cloud Dataflow job.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
-   * [location] - The location that contains this job.
-   *
-   * [replaceJobId] - Deprecated. This field is now in the Job message.
-   *
    * [view] - The 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.
    * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
+   * [location] - The location that contains this job.
+   *
+   * [replaceJobId] - Deprecated. This field is now in 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 location, core.String replaceJobId, core.String view}) {
+  async.Future<Job> create(Job request, core.String projectId, {core.String view, core.String location, 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 (view != null) {
+      _queryParams["view"] = [view];
+    }
     if (location != null) {
       _queryParams["location"] = [location];
     }
     if (replaceJobId != null) {
       _queryParams["replaceJobId"] = [replaceJobId];
     }
-    if (view != null) {
-      _queryParams["view"] = [view];
-    }
 
     _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 Cloud Dataflow job.
    *
    * Request parameters:
    *
    * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
    * [jobId] - The job ID.
    *
+   * [location] - The location that contains this job.
+   *
    * [view] - The 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.
    * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
-   * [location] - The location that 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}) {
+  async.Future<Job> get(core.String projectId, core.String jobId, {core.String location, 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 (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
     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);
@@ skipping 306 matching lines @@
 
   /**
    * Request the job status.
    *
    * Request parameters:
    *
    * [projectId] - A project id.
    *
    * [jobId] - The job to get messages about.
    *
+   * [location] - The location which contains the job specified by job_id.
+   *
+   * [endTime] - Return only messages with timestamps < end_time. The default is
+   * now
+   * (i.e. return up to the latest messages available).
+   *
+   * [startTime] - If specified, return only messages with timestamps >=
+   * start_time.
+   * The default is the job creation time (i.e. beginning of messages).
+   *
+   * [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.
+   *
    * [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.
    *
    * [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.
    *
-   * [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.
-   *
-   * [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).
-   *
    * 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.int pageSize, core.String minimumImportance, core.String endTime, core.String location, core.String pageToken, core.String startTime}) {
+  async.Future<ListJobMessagesResponse> list(core.String projectId, core.String jobId, {core.String location, core.String endTime, core.String startTime, core.String pageToken, core.int pageSize, core.String minimumImportance}) {
     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 (location != null) {
+      _queryParams["location"] = [location];
+    }
+    if (endTime != null) {
+      _queryParams["endTime"] = [endTime];
+    }
+    if (startTime != null) {
+      _queryParams["startTime"] = [startTime];
+    }
+    if (pageToken != null) {
+      _queryParams["pageToken"] = [pageToken];
+    }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (minimumImportance != null) {
       _queryParams["minimumImportance"] = [minimumImportance];
     }
-    if (endTime != null) {
-      _queryParams["endTime"] = [endTime];
-    }
-    if (location != null) {
-      _queryParams["location"] = [location];
-    }
-    if (pageToken != null) {
-      _queryParams["pageToken"] = [pageToken];
-    }
-    if (startTime != null) {
-      _queryParams["startTime"] = [startTime];
-    }
 
     _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);
@@ skipping 107 matching lines @@
     return _response.then((data) => new ReportWorkItemStatusResponse.fromJson(data));
   }
 
 }
 
 
 class ProjectsLocationsResourceApi {
   final commons.ApiRequester _requester;
 
   ProjectsLocationsJobsResourceApi get jobs => new ProjectsLocationsJobsResourceApi(_requester);
+  ProjectsLocationsTemplatesResourceApi get templates => new ProjectsLocationsTemplatesResourceApi(_requester);
 
   ProjectsLocationsResourceApi(commons.ApiRequester client) : 
       _requester = client;
+
+  /**
+   * Send a worker_message to the service.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project to send the WorkerMessages to.
+   *
+   * [location] - The location which contains the job
+   *
+   * Completes with a [SendWorkerMessagesResponse].
+   *
+   * 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<SendWorkerMessagesResponse> workerMessages(SendWorkerMessagesRequest request, core.String projectId, 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 (location == null) {
+      throw new core.ArgumentError("Parameter location is required.");
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/WorkerMessages';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new SendWorkerMessagesResponse.fromJson(data));
+  }
+
 }
 
 
 class ProjectsLocationsJobsResourceApi {
   final commons.ApiRequester _requester;
 
+  ProjectsLocationsJobsDebugResourceApi get debug => new ProjectsLocationsJobsDebugResourceApi(_requester);
   ProjectsLocationsJobsMessagesResourceApi get messages => new ProjectsLocationsJobsMessagesResourceApi(_requester);
   ProjectsLocationsJobsWorkItemsResourceApi get workItems => new ProjectsLocationsJobsWorkItemsResourceApi(_requester);
 
   ProjectsLocationsJobsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
    * Creates a Cloud Dataflow job.
    *
    * [request] - The metadata request object.
@@ skipping 173 matching lines @@
 
   /**
    * List the jobs of a project.
    *
    * Request parameters:
    *
    * [projectId] - The project which owns the jobs.
    *
    * [location] - The location that 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.
+   *
+   * [pageToken] - Set this to the 'next_page_token' field of a previous
+   * response
+   * to request additional results in a long list.
+   *
    * [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.
    *
    * [view] - Level of information requested in response. Default is
    * `JOB_VIEW_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.
    * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
-   * [filter] - The kind of filter to use.
-   * Possible string values are:
-   * - "UNKNOWN" : A UNKNOWN.
-   * - "ALL" : A ALL.
-   * - "TERMINATED" : A TERMINATED.
-   * - "ACTIVE" : A ACTIVE.
-   *
-   * [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 location, {core.int pageSize, core.String view, core.String filter, core.String pageToken}) {
+  async.Future<ListJobsResponse> list(core.String projectId, core.String location, {core.String filter, core.String pageToken, core.int pageSize, 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 (filter != null) {
+      _queryParams["filter"] = [filter];
+    }
+    if (pageToken != null) {
+      _queryParams["pageToken"] = [pageToken];
+    }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (view != null) {
       _queryParams["view"] = [view];
     }
-    if (filter != null) {
-      _queryParams["filter"] = [filter];
-    }
-    if (pageToken != null) {
-      _queryParams["pageToken"] = [pageToken];
-    }
 
     _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);
@@ skipping 50 matching lines @@
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
 }
 
 
+class ProjectsLocationsJobsDebugResourceApi {
+  final commons.ApiRequester _requester;
+
+  ProjectsLocationsJobsDebugResourceApi(commons.ApiRequester client) : 
+      _requester = client;
+
+  /**
+   * Get encoded debug configuration for component. Not cacheable.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - The project id.
+   *
+   * [location] - The location which contains the job specified by job_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 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') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/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.
+   *
+   * [location] - The location which contains the job specified by job_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 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') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/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 ProjectsLocationsJobsMessagesResourceApi {
   final commons.ApiRequester _requester;
 
   ProjectsLocationsJobsMessagesResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
    * Request the job status.
    *
    * Request parameters:
@@ skipping 102 matching lines @@
    * [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 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') + '/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 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') + '/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));
+  }
+
+}
+
+
+class ProjectsLocationsTemplatesResourceApi {
+  final commons.ApiRequester _requester;
+
+  ProjectsLocationsTemplatesResourceApi(commons.ApiRequester client) : 
+      _requester = client;
+
+  /**
+   * Creates a Cloud Dataflow job from a template.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [projectId] - Required. The ID of the Cloud Platform project that the job
+   * belongs to.
+   *
+   * [location] - The location to which to direct the request.
+   *
+   * 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(CreateJobFromTemplateRequest request, core.String projectId, 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 (location == null) {
+      throw new core.ArgumentError("Parameter location is required.");
+    }
+
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/templates';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new Job.fromJson(data));
+  }
+
+  /**
+   * Get the template associated with a template.
+   *
+   * Request parameters:
+   *
+   * [projectId] - Required. The ID of the Cloud Platform project that the job
+   * belongs to.
+   *
+   * [location] - The location to which to direct the request.
+   *
+   * [view] - The view to retrieve. Defaults to METADATA_ONLY.
+   * Possible string values are:
+   * - "METADATA_ONLY" : A METADATA_ONLY.
+   *
+   * [gcsPath] - Required. A Cloud Storage path to the template from which to
+   * create the job.
+   * Must be a valid Cloud Storage URL, beginning with `gs://`.
+   *
+   * Completes with a [GetTemplateResponse].
+   *
+   * 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 location, core.String jobId) {
+  async.Future<GetTemplateResponse> get(core.String projectId, core.String location, {core.String view, core.String gcsPath}) {
     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.");
+    if (view != null) {
+      _queryParams["view"] = [view];
+    }
+    if (gcsPath != null) {
+      _queryParams["gcsPath"] = [gcsPath];
     }
 
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/workItems:lease';
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/templates:get';
 
     var _response = _requester.request(_url,
-                                       "POST",
+                                       "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
-    return _response.then((data) => new LeaseWorkItemResponse.fromJson(data));
+    return _response.then((data) => new GetTemplateResponse.fromJson(data));
   }
 
   /**
-   * Reports the status of dataflow WorkItems leased by a worker.
+   * Launch a template.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
-   * [projectId] - The project which owns the WorkItem's job.
+   * [projectId] - Required. The ID of the Cloud Platform project that the job
+   * belongs to.
    *
-   * [location] - The location which contains the WorkItem's job.
+   * [location] - The location to which to direct the request.
    *
-   * [jobId] - The job which the WorkItem is part of.
+   * [gcsPath] - Required. A Cloud Storage path to the template from which to
+   * create
+   * the job.
+   * Must be valid Cloud Storage URL, beginning with 'gs://'.
    *
-   * Completes with a [ReportWorkItemStatusResponse].
+   * [dryRun] - Whether or not the job should actually be executed after
+   * validating parameters. Defaults to false. Validation errors do
+   * not cause the HTTP request to fail if true.
+   *
+   * Completes with a [LaunchTemplateResponse].
    *
    * 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 location, core.String jobId) {
+  async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request, core.String projectId, core.String location, {core.String gcsPath, core.bool dryRun}) {
     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.");
+    if (gcsPath != null) {
+      _queryParams["gcsPath"] = [gcsPath];
+    }
+    if (dryRun != null) {
+      _queryParams["dryRun"] = ["${dryRun}"];
     }
 
-    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/workItems:reportStatus';
+    _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/templates:launch';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
-    return _response.then((data) => new ReportWorkItemStatusResponse.fromJson(data));
+    return _response.then((data) => new LaunchTemplateResponse.fromJson(data));
   }
 
 }
 
 
 class ProjectsTemplatesResourceApi {
   final commons.ApiRequester _requester;
 
   ProjectsTemplatesResourceApi(commons.ApiRequester client) : 
       _requester = client;
@@ skipping 52 matching lines @@
    * belongs to.
    *
    * [view] - The view to retrieve. Defaults to METADATA_ONLY.
    * Possible string values are:
    * - "METADATA_ONLY" : A METADATA_ONLY.
    *
    * [gcsPath] - Required. A Cloud Storage path to the template from which to
    * create the job.
    * Must be a valid Cloud Storage URL, beginning with `gs://`.
    *
+   * [location] - The location to which to direct the request.
+   *
    * Completes with a [GetTemplateResponse].
    *
    * 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<GetTemplateResponse> get(core.String projectId, {core.String view, core.String gcsPath}) {
+  async.Future<GetTemplateResponse> get(core.String projectId, {core.String view, core.String gcsPath, 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 (view != null) {
       _queryParams["view"] = [view];
     }
     if (gcsPath != null) {
       _queryParams["gcsPath"] = [gcsPath];
     }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/templates:get';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 12 matching lines @@
    *
    * [gcsPath] - Required. A Cloud Storage path to the template from which to
    * create
    * the job.
    * Must be valid Cloud Storage URL, beginning with 'gs://'.
    *
    * [dryRun] - Whether or not the job should actually be executed after
    * validating parameters. Defaults to false. Validation errors do
    * not cause the HTTP request to fail if true.
    *
+   * [location] - The location to which to direct the request.
+   *
    * Completes with a [LaunchTemplateResponse].
    *
    * 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<LaunchTemplateResponse> launch(LaunchTemplateParameters request, core.String projectId, {core.String gcsPath, core.bool dryRun}) {
+  async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request, core.String projectId, {core.String gcsPath, core.bool dryRun, 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 (gcsPath != null) {
       _queryParams["gcsPath"] = [gcsPath];
     }
     if (dryRun != null) {
       _queryParams["dryRun"] = ["${dryRun}"];
     }
+    if (location != null) {
+      _queryParams["location"] = [location];
+    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/templates:launch';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 154 matching lines @@
     if (fractionConsumed != null) {
       _json["fractionConsumed"] = fractionConsumed;
     }
     if (position != null) {
       _json["position"] = (position).toJson();
     }
     return _json;
   }
 }
 
+/**
+ * A structured message reporting an autoscaling decision made by the Dataflow
+ * service.
+ */
+class AutoscalingEvent {
+  /** The current number of workers the job has. */
+  core.String currentNumWorkers;
+  /**
+   * A message describing why the system decided to adjust the current
+   * number of workers, why it failed, or why the system decided to
+   * not make any changes to the number of workers.
+   */
+  StructuredMessage description;
+  /**
+   * The type of autoscaling event to report.
+   * Possible string values are:
+   * - "TYPE_UNKNOWN" : Default type for the enum.  Value should never be
+   * returned.
+   * - "TARGET_NUM_WORKERS_CHANGED" : The TARGET_NUM_WORKERS_CHANGED type should
+   * be used when the target
+   * worker pool size has changed at the start of an actuation. An event
+   * should always be specified as TARGET_NUM_WORKERS_CHANGED if it reflects
+   * a change in the target_num_workers.
+   * - "CURRENT_NUM_WORKERS_CHANGED" : The CURRENT_NUM_WORKERS_CHANGED type
+   * should be used when actual worker
+   * pool size has been changed, but the target_num_workers has not changed.
+   * - "ACTUATION_FAILURE" : The ACTUATION_FAILURE type should be used when we
+   * want to report
+   * an error to the user indicating why the current number of workers
+   * in the pool could not be changed.
+   * Displayed in the current status and history widgets.
+   * - "NO_CHANGE" : Used when we want to report to the user a reason why we are
+   * not currently adjusting the number of workers.
+   * Should specify both target_num_workers, current_num_workers and a
+   * decision_message.
+   */
+  core.String eventType;
+  /** The target number of workers the worker pool wants to resize to use. */
+  core.String targetNumWorkers;
+  /**
+   * The time this event was emitted to indicate a new target or current
+   * num_workers value.
+   */
+  core.String time;
+
+  AutoscalingEvent();
+
+  AutoscalingEvent.fromJson(core.Map _json) {
+    if (_json.containsKey("currentNumWorkers")) {
+      currentNumWorkers = _json["currentNumWorkers"];
+    }
+    if (_json.containsKey("description")) {
+      description = new StructuredMessage.fromJson(_json["description"]);
+    }
+    if (_json.containsKey("eventType")) {
+      eventType = _json["eventType"];
+    }
+    if (_json.containsKey("targetNumWorkers")) {
+      targetNumWorkers = _json["targetNumWorkers"];
+    }
+    if (_json.containsKey("time")) {
+      time = _json["time"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (currentNumWorkers != null) {
+      _json["currentNumWorkers"] = currentNumWorkers;
+    }
+    if (description != null) {
+      _json["description"] = (description).toJson();
+    }
+    if (eventType != null) {
+      _json["eventType"] = eventType;
+    }
+    if (targetNumWorkers != null) {
+      _json["targetNumWorkers"] = targetNumWorkers;
+    }
+    if (time != null) {
+      _json["time"] = time;
+    }
+    return _json;
+  }
+}
+
 /** Settings for WorkerPool autoscaling. */
 class AutoscalingSettings {
   /**
    * The algorithm to use for autoscaling.
    * Possible string values are:
    * - "AUTOSCALING_ALGORITHM_UNKNOWN" : The algorithm is unknown, or
    * unspecified.
    * - "AUTOSCALING_ALGORITHM_NONE" : Disable autoscaling.
    * - "AUTOSCALING_ALGORITHM_BASIC" : Increase worker count over time to reduce
    * job execution time.
@@ skipping 615 matching lines @@
   /** The runtime environment for the job. */
   RuntimeEnvironment environment;
   /**
    * Required. A Cloud Storage path to the template from which to
    * create the job.
    * Must be a valid Cloud Storage URL, beginning with `gs://`.
    */
   core.String gcsPath;
   /** Required. The job name to use for the created job. */
   core.String jobName;
+  /** The location to which to direct the request. */
+  core.String location;
   /** The runtime parameters to pass to the job. */
   core.Map<core.String, core.String> parameters;
 
   CreateJobFromTemplateRequest();
 
   CreateJobFromTemplateRequest.fromJson(core.Map _json) {
     if (_json.containsKey("environment")) {
       environment = new RuntimeEnvironment.fromJson(_json["environment"]);
     }
     if (_json.containsKey("gcsPath")) {
       gcsPath = _json["gcsPath"];
     }
     if (_json.containsKey("jobName")) {
       jobName = _json["jobName"];
     }
+    if (_json.containsKey("location")) {
+      location = _json["location"];
+    }
     if (_json.containsKey("parameters")) {
       parameters = _json["parameters"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (environment != null) {
       _json["environment"] = (environment).toJson();
     }
     if (gcsPath != null) {
       _json["gcsPath"] = gcsPath;
     }
     if (jobName != null) {
       _json["jobName"] = jobName;
     }
+    if (location != null) {
+      _json["location"] = location;
+    }
     if (parameters != null) {
       _json["parameters"] = parameters;
     }
     return _json;
   }
 }
 
 /** Identifies the location of a custom souce. */
 class CustomSourceLocation {
   /** Whether this source is stateful. */
@@ skipping 525 matching lines @@
     if (version != null) {
       _json["version"] = version;
     }
     if (workerPools != null) {
       _json["workerPools"] = workerPools.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
+/** A message describing the state of a particular execution stage. */
+class ExecutionStageState {
+  /** The time at which the stage transitioned to this state. */
+  core.String currentStateTime;
+  /** The name of the execution stage. */
+  core.String executionStageName;
+  /**
+   * Executions stage states allow the same set of values as JobState.
+   * Possible string values are:
+   * - "JOB_STATE_UNKNOWN" : The job's run state isn't specified.
+   * - "JOB_STATE_STOPPED" : `JOB_STATE_STOPPED` indicates that the job has not
+   * yet started to run.
+   * - "JOB_STATE_RUNNING" : `JOB_STATE_RUNNING` indicates that the job is
+   * currently running.
+   * - "JOB_STATE_DONE" : `JOB_STATE_DONE` indicates that the job has
+   * successfully completed.
+   * This is a terminal job state.  This state may be set by the Cloud Dataflow
+   * service, as a transition from `JOB_STATE_RUNNING`. It may also be set via a
+   * Cloud Dataflow `UpdateJob` call, if the job has not yet reached a terminal
+   * state.
+   * - "JOB_STATE_FAILED" : `JOB_STATE_FAILED` indicates that the job has
+   * failed.  This is a
+   * terminal job state.  This state may only be set by the Cloud Dataflow
+   * service, and only as a transition from `JOB_STATE_RUNNING`.
+   * - "JOB_STATE_CANCELLED" : `JOB_STATE_CANCELLED` indicates that the job has
+   * been explicitly
+   * cancelled. This is a terminal job state. This state may only be
+   * set via a Cloud Dataflow `UpdateJob` call, and only if the job has not
+   * yet reached another terminal state.
+   * - "JOB_STATE_UPDATED" : `JOB_STATE_UPDATED` indicates that the job was
+   * successfully updated,
+   * meaning that this job was stopped and another job was started, inheriting
+   * state from this one. This is a terminal job state. This state may only be
+   * set by the Cloud Dataflow service, and only as a transition from
+   * `JOB_STATE_RUNNING`.
+   * - "JOB_STATE_DRAINING" : `JOB_STATE_DRAINING` indicates that the job is in
+   * the process of draining.
+   * A draining job has stopped pulling from its input sources and is processing
+   * any data that remains in-flight. This state may be set via a Cloud Dataflow
+   * `UpdateJob` call, but only as a transition from `JOB_STATE_RUNNING`. Jobs
+   * that are draining may only transition to `JOB_STATE_DRAINED`,
+   * `JOB_STATE_CANCELLED`, or `JOB_STATE_FAILED`.
+   * - "JOB_STATE_DRAINED" : `JOB_STATE_DRAINED` indicates that the job has been
+   * drained.
+   * A drained job terminated by stopping pulling from its input sources and
+   * processing any data that remained in-flight when draining was requested.
+   * This state is a terminal state, may only be set by the Cloud Dataflow
+   * service, and only as a transition from `JOB_STATE_DRAINING`.
+   * - "JOB_STATE_PENDING" : 'JOB_STATE_PENDING' indicates that the job has been
+   * created but is not yet
+   * running.  Jobs that are pending may only transition to `JOB_STATE_RUNNING`,
+   * or `JOB_STATE_FAILED`.
+   * - "JOB_STATE_CANCELLING" : 'JOB_STATE_CANCELLING' indicates that the job
+   * has been explicitly cancelled
+   * and is in the process of stopping.  Jobs that are cancelling may only
+   * transition to 'JOB_STATE_CANCELLED' or 'JOB_STATE_FAILED'.
+   */
+  core.String executionStageState;
+
+  ExecutionStageState();
+
+  ExecutionStageState.fromJson(core.Map _json) {
+    if (_json.containsKey("currentStateTime")) {
+      currentStateTime = _json["currentStateTime"];
+    }
+    if (_json.containsKey("executionStageName")) {
+      executionStageName = _json["executionStageName"];
+    }
+    if (_json.containsKey("executionStageState")) {
+      executionStageState = _json["executionStageState"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (currentStateTime != null) {
+      _json["currentStateTime"] = currentStateTime;
+    }
+    if (executionStageName != null) {
+      _json["executionStageName"] = executionStageName;
+    }
+    if (executionStageState != null) {
+      _json["executionStageState"] = executionStageState;
+    }
+    return _json;
+  }
+}
+
 /**
  * Description of the composing transforms, names/ids, and input/outputs of a
  * stage of execution.  Some composing transforms and sources may have been
  * generated by the Dataflow service during execution planning.
  */
 class ExecutionStageSummary {
   /**
    * Collections produced and consumed by component transforms of this stage.
    */
   core.List<ComponentSource> componentSource;
@@ skipping 175 matching lines @@
   }
 }
 
 /** Request to get updated debug configuration for component. */
 class GetDebugConfigRequest {
   /**
    * The internal component id for which debug configuration is
    * requested.
    */
   core.String componentId;
+  /** The location which contains the job specified by job_id. */
+  core.String location;
   /** The worker id, i.e., VM hostname. */
   core.String workerId;
 
   GetDebugConfigRequest();
 
   GetDebugConfigRequest.fromJson(core.Map _json) {
     if (_json.containsKey("componentId")) {
       componentId = _json["componentId"];
     }
+    if (_json.containsKey("location")) {
+      location = _json["location"];
+    }
     if (_json.containsKey("workerId")) {
       workerId = _json["workerId"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (componentId != null) {
       _json["componentId"] = componentId;
     }
+    if (location != null) {
+      _json["location"] = location;
+    }
     if (workerId != null) {
       _json["workerId"] = workerId;
     }
     return _json;
   }
 }
 
 /** Response to a get debug configuration request. */
 class GetDebugConfigResponse {
   /** The encoded debug configuration for the requested component. */
@@ skipping 283 matching lines @@
    * any data that remains in-flight. This state may be set via a Cloud Dataflow
    * `UpdateJob` call, but only as a transition from `JOB_STATE_RUNNING`. Jobs
    * that are draining may only transition to `JOB_STATE_DRAINED`,
    * `JOB_STATE_CANCELLED`, or `JOB_STATE_FAILED`.
    * - "JOB_STATE_DRAINED" : `JOB_STATE_DRAINED` indicates that the job has been
    * drained.
    * A drained job terminated by stopping pulling from its input sources and
    * processing any data that remained in-flight when draining was requested.
    * This state is a terminal state, may only be set by the Cloud Dataflow
    * service, and only as a transition from `JOB_STATE_DRAINING`.
+   * - "JOB_STATE_PENDING" : 'JOB_STATE_PENDING' indicates that the job has been
+   * created but is not yet
+   * running.  Jobs that are pending may only transition to `JOB_STATE_RUNNING`,
+   * or `JOB_STATE_FAILED`.
+   * - "JOB_STATE_CANCELLING" : 'JOB_STATE_CANCELLING' indicates that the job
+   * has been explicitly cancelled
+   * and is in the process of stopping.  Jobs that are cancelling may only
+   * transition to 'JOB_STATE_CANCELLED' or 'JOB_STATE_FAILED'.
    */
   core.String currentState;
   /** The timestamp associated with the current state. */
   core.String currentStateTime;
   /** The environment for the job. */
   Environment environment;
   /** Deprecated. */
   JobExecutionInfo executionInfo;
   /**
    * The unique ID of this job.
@@ skipping 92 matching lines @@
    * any data that remains in-flight. This state may be set via a Cloud Dataflow
    * `UpdateJob` call, but only as a transition from `JOB_STATE_RUNNING`. Jobs
    * that are draining may only transition to `JOB_STATE_DRAINED`,
    * `JOB_STATE_CANCELLED`, or `JOB_STATE_FAILED`.
    * - "JOB_STATE_DRAINED" : `JOB_STATE_DRAINED` indicates that the job has been
    * drained.
    * A drained job terminated by stopping pulling from its input sources and
    * processing any data that remained in-flight when draining was requested.
    * This state is a terminal state, may only be set by the Cloud Dataflow
    * service, and only as a transition from `JOB_STATE_DRAINING`.
+   * - "JOB_STATE_PENDING" : 'JOB_STATE_PENDING' indicates that the job has been
+   * created but is not yet
+   * running.  Jobs that are pending may only transition to `JOB_STATE_RUNNING`,
+   * or `JOB_STATE_FAILED`.
+   * - "JOB_STATE_CANCELLING" : 'JOB_STATE_CANCELLING' indicates that the job
+   * has been explicitly cancelled
+   * and is in the process of stopping.  Jobs that are cancelling may only
+   * transition to 'JOB_STATE_CANCELLED' or 'JOB_STATE_FAILED'.
    */
   core.String requestedState;
+  /**
+   * This field may be mutated by the Cloud Dataflow service;
+   * callers cannot mutate it.
+   */
+  core.List<ExecutionStageState> stageStates;
   /** The top-level steps that constitute the entire job. */
   core.List<Step> steps;
   /**
    * A set of files the system should be aware of that are used
    * for temporary storage. These temporary files will be
    * removed on job completion.
    * No duplicates are allowed.
    * No file patterns are supported.
    *
    * The supported files are:
@@ skipping 63 matching lines @@
     }
     if (_json.containsKey("replaceJobId")) {
       replaceJobId = _json["replaceJobId"];
     }
     if (_json.containsKey("replacedByJobId")) {
       replacedByJobId = _json["replacedByJobId"];
     }
     if (_json.containsKey("requestedState")) {
       requestedState = _json["requestedState"];
     }
+    if (_json.containsKey("stageStates")) {
+      stageStates = _json["stageStates"].map((value) => new ExecutionStageState.fromJson(value)).toList();
+    }
     if (_json.containsKey("steps")) {
       steps = _json["steps"].map((value) => new Step.fromJson(value)).toList();
     }
     if (_json.containsKey("tempFiles")) {
       tempFiles = _json["tempFiles"];
     }
     if (_json.containsKey("transformNameMapping")) {
       transformNameMapping = _json["transformNameMapping"];
     }
     if (_json.containsKey("type")) {
@@ skipping 41 matching lines @@
     }
     if (replaceJobId != null) {
       _json["replaceJobId"] = replaceJobId;
     }
     if (replacedByJobId != null) {
       _json["replacedByJobId"] = replacedByJobId;
     }
     if (requestedState != null) {
       _json["requestedState"] = requestedState;
     }
+    if (stageStates != null) {
+      _json["stageStates"] = stageStates.map((value) => (value).toJson()).toList();
+    }
     if (steps != null) {
       _json["steps"] = steps.map((value) => (value).toJson()).toList();
     }
     if (tempFiles != null) {
       _json["tempFiles"] = tempFiles;
     }
     if (transformNameMapping != null) {
       _json["transformNameMapping"] = transformNameMapping;
     }
     if (type != null) {
@@ skipping 52 matching lines @@
     var _json = new core.Map();
     if (stepName != null) {
       _json["stepName"] = stepName;
     }
     return _json;
   }
 }
 
 /** A particular message pertaining to a Dataflow job. */
 class JobMessage {
-  /**
-   * Identifies the message.  This is automatically generated by the
-   * service; the caller should treat it as an opaque string.
-   */
+  /** Deprecated. */
   core.String id;
   /**
    * Importance level of the message.
    * Possible string values are:
    * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : The message importance isn't
    * specified, or is unknown.
    * - "JOB_MESSAGE_DEBUG" : The message is at the 'debug' level: typically only
    * useful for
    * software engineers working on the code the job is running.
    * Typically, Dataflow pipeline runners do not display log messages
@@ skipping 366 matching lines @@
     var _json = new core.Map();
     if (workItems != null) {
       _json["workItems"] = workItems.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 /** Response to a request to list job messages. */
 class ListJobMessagesResponse {
+  /** Autoscaling events in ascending timestamp order. */
+  core.List<AutoscalingEvent> autoscalingEvents;
   /** Messages in ascending timestamp order. */
   core.List<JobMessage> jobMessages;
   /** The token to obtain the next page of results if there are more. */
   core.String nextPageToken;
 
   ListJobMessagesResponse();
 
   ListJobMessagesResponse.fromJson(core.Map _json) {
+    if (_json.containsKey("autoscalingEvents")) {
+      autoscalingEvents = _json["autoscalingEvents"].map((value) => new AutoscalingEvent.fromJson(value)).toList();
+    }
     if (_json.containsKey("jobMessages")) {
       jobMessages = _json["jobMessages"].map((value) => new JobMessage.fromJson(value)).toList();
     }
     if (_json.containsKey("nextPageToken")) {
       nextPageToken = _json["nextPageToken"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (autoscalingEvents != null) {
+      _json["autoscalingEvents"] = autoscalingEvents.map((value) => (value).toJson()).toList();
+    }
     if (jobMessages != null) {
       _json["jobMessages"] = jobMessages.map((value) => (value).toJson()).toList();
     }
     if (nextPageToken != null) {
       _json["nextPageToken"] = nextPageToken;
     }
     return _json;
   }
 }
 
@@ skipping 604 matching lines @@
     if (systemName != null) {
       _json["systemName"] = systemName;
     }
     if (write != null) {
       _json["write"] = (write).toJson();
     }
     return _json;
   }
 }
 
+/** Structured data associated with this message. */
+class Parameter {
+  /** Key or name for this parameter. */
+  core.String key;
+  /**
+   * Value for this parameter.
+   *
+   * 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.Object value;
+
+  Parameter();
+
+  Parameter.fromJson(core.Map _json) {
+    if (_json.containsKey("key")) {
+      key = _json["key"];
+    }
+    if (_json.containsKey("value")) {
+      value = _json["value"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (key != null) {
+      _json["key"] = key;
+    }
+    if (value != null) {
+      _json["value"] = value;
+    }
+    return _json;
+  }
+}
+
 /** Metadata for a specific parameter. */
 class ParameterMetadata {
   /** Required. The help text to display for the parameter. */
   core.String helpText;
   /** Optional. Whether the parameter is optional. Defaults to false. */
   core.bool isOptional;
   /** Required. The label to display for the parameter. */
   core.String label;
   /** Required. The name of the parameter. */
   core.String name;
@@ skipping 579 matching lines @@
     return _json;
   }
 }
 
 /** Request to send encoded debug information. */
 class SendDebugCaptureRequest {
   /** The internal component id for which debug information is sent. */
   core.String componentId;
   /** The encoded debug information. */
   core.String data;
+  /** The location which contains the job specified by job_id. */
+  core.String location;
   /** The worker id, i.e., VM hostname. */
   core.String workerId;
 
   SendDebugCaptureRequest();
 
   SendDebugCaptureRequest.fromJson(core.Map _json) {
     if (_json.containsKey("componentId")) {
       componentId = _json["componentId"];
     }
     if (_json.containsKey("data")) {
       data = _json["data"];
     }
+    if (_json.containsKey("location")) {
+      location = _json["location"];
+    }
     if (_json.containsKey("workerId")) {
       workerId = _json["workerId"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (componentId != null) {
       _json["componentId"] = componentId;
     }
     if (data != null) {
       _json["data"] = data;
     }
+    if (location != null) {
+      _json["location"] = location;
+    }
     if (workerId != null) {
       _json["workerId"] = workerId;
     }
     return _json;
   }
 }
 
 /**
  * Response to a send capture request.
  * nothing
  */
 class SendDebugCaptureResponse {
 
   SendDebugCaptureResponse();
 
   SendDebugCaptureResponse.fromJson(core.Map _json) {
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     return _json;
   }
 }
 
 /** A request for sending worker messages to the service. */
 class SendWorkerMessagesRequest {
+  /** The location which contains the job */
+  core.String location;
   /** The WorkerMessages to send. */
   core.List<WorkerMessage> workerMessages;
 
   SendWorkerMessagesRequest();
 
   SendWorkerMessagesRequest.fromJson(core.Map _json) {
+    if (_json.containsKey("location")) {
+      location = _json["location"];
+    }
     if (_json.containsKey("workerMessages")) {
       workerMessages = _json["workerMessages"].map((value) => new WorkerMessage.fromJson(value)).toList();
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (location != null) {
+      _json["location"] = location;
+    }
     if (workerMessages != null) {
       _json["workerMessages"] = workerMessages.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 /** The response to the worker messages. */
 class SendWorkerMessagesResponse {
   /** The servers response to the worker messages. */
@@ skipping 1356 matching lines @@
 
   core.Map toJson() {
     var _json = new core.Map();
     if (elements != null) {
       _json["elements"] = elements;
     }
     return _json;
   }
 }
 
+/**
+ * A rich message format, including a human readable string, a key for
+ * identifying the message, and structured data associated with the message for
+ * programmatic consumption.
+ */
+class StructuredMessage {
+  /**
+   * Idenfier for this message type.  Used by external systems to
+   * internationalize or personalize message.
+   */
+  core.String messageKey;
+  /** Human-readable version of message. */
+  core.String messageText;
+  /** The structured data associated with this message. */
+  core.List<Parameter> parameters;
+
+  StructuredMessage();
+
+  StructuredMessage.fromJson(core.Map _json) {
+    if (_json.containsKey("messageKey")) {
+      messageKey = _json["messageKey"];
+    }
+    if (_json.containsKey("messageText")) {
+      messageText = _json["messageText"];
+    }
+    if (_json.containsKey("parameters")) {
+      parameters = _json["parameters"].map((value) => new Parameter.fromJson(value)).toList();
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (messageKey != null) {
+      _json["messageKey"] = messageKey;
+    }
+    if (messageText != null) {
+      _json["messageText"] = messageText;
+    }
+    if (parameters != null) {
+      _json["parameters"] = parameters.map((value) => (value).toJson()).toList();
+    }
+    return _json;
+  }
+}
+
 /** Taskrunner configuration settings. */
 class TaskRunnerSettings {
   /** Whether to also send taskrunner log info to stderr. */
   core.bool alsologtostderr;
   /** The location on the worker for task-specific subdirectories. */
   core.String baseTaskDir;
   /**
    * The base URL for the taskrunner to use when accessing Google Cloud APIs.
    *
    * When workers access Google Cloud APIs, they logically do so via
@@ skipping 1447 matching lines @@
     var _json = new core.Map();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     return _json;
   }
 }