Api-roll 48: 2017-04-18

generated/googleapis_beta/test/dataflow/v1b3_test.dart

 library googleapis_beta.dataflow.v1b3.test;
 
 import "dart:core" as core;
 import "dart:collection" as collection;
 import "dart:async" as async;
 import "dart:convert" as convert;
 
 import 'package:http/http.dart' as http;
 import 'package:http/testing.dart' as http_testing;
 import 'package:unittest/unittest.dart' as unittest;
@@ skipping 102 matching lines @@
 
 checkApproximateSplitRequest(api.ApproximateSplitRequest o) {
   buildCounterApproximateSplitRequest++;
   if (buildCounterApproximateSplitRequest < 3) {
     unittest.expect(o.fractionConsumed, unittest.equals(42.0));
     checkPosition(o.position);
   }
   buildCounterApproximateSplitRequest--;
 }
 
+core.int buildCounterAutoscalingEvent = 0;
+buildAutoscalingEvent() {
+  var o = new api.AutoscalingEvent();
+  buildCounterAutoscalingEvent++;
+  if (buildCounterAutoscalingEvent < 3) {
+    o.currentNumWorkers = "foo";
+    o.description = buildStructuredMessage();
+    o.eventType = "foo";
+    o.targetNumWorkers = "foo";
+    o.time = "foo";
+  }
+  buildCounterAutoscalingEvent--;
+  return o;
+}
+
+checkAutoscalingEvent(api.AutoscalingEvent o) {
+  buildCounterAutoscalingEvent++;
+  if (buildCounterAutoscalingEvent < 3) {
+    unittest.expect(o.currentNumWorkers, unittest.equals('foo'));
+    checkStructuredMessage(o.description);
+    unittest.expect(o.eventType, unittest.equals('foo'));
+    unittest.expect(o.targetNumWorkers, unittest.equals('foo'));
+    unittest.expect(o.time, unittest.equals('foo'));
+  }
+  buildCounterAutoscalingEvent--;
+}
+
 core.int buildCounterAutoscalingSettings = 0;
 buildAutoscalingSettings() {
   var o = new api.AutoscalingSettings();
   buildCounterAutoscalingSettings++;
   if (buildCounterAutoscalingSettings < 3) {
     o.algorithm = "foo";
     o.maxNumWorkers = 42;
   }
   buildCounterAutoscalingSettings--;
   return o;
@@ skipping 70 matching lines @@
 checkComponentTransform(api.ComponentTransform o) {
   buildCounterComponentTransform++;
   if (buildCounterComponentTransform < 3) {
     unittest.expect(o.name, unittest.equals('foo'));
     unittest.expect(o.originalTransform, unittest.equals('foo'));
     unittest.expect(o.userName, unittest.equals('foo'));
   }
   buildCounterComponentTransform--;
 }
 
-buildUnnamed3083() {
+buildUnnamed3086() {
   var o = new core.List<api.StreamLocation>();
   o.add(buildStreamLocation());
   o.add(buildStreamLocation());
   return o;
 }
 
-checkUnnamed3083(core.List<api.StreamLocation> o) {
+checkUnnamed3086(core.List<api.StreamLocation> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStreamLocation(o[0]);
   checkStreamLocation(o[1]);
 }
 
-buildUnnamed3084() {
+buildUnnamed3087() {
   var o = new core.List<api.KeyRangeLocation>();
   o.add(buildKeyRangeLocation());
   o.add(buildKeyRangeLocation());
   return o;
 }
 
-checkUnnamed3084(core.List<api.KeyRangeLocation> o) {
+checkUnnamed3087(core.List<api.KeyRangeLocation> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkKeyRangeLocation(o[0]);
   checkKeyRangeLocation(o[1]);
 }
 
-buildUnnamed3085() {
+buildUnnamed3088() {
   var o = new core.List<api.StreamLocation>();
   o.add(buildStreamLocation());
   o.add(buildStreamLocation());
   return o;
 }
 
-checkUnnamed3085(core.List<api.StreamLocation> o) {
+checkUnnamed3088(core.List<api.StreamLocation> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStreamLocation(o[0]);
   checkStreamLocation(o[1]);
 }
 
-buildUnnamed3086() {
+buildUnnamed3089() {
   var o = new core.List<api.StateFamilyConfig>();
   o.add(buildStateFamilyConfig());
   o.add(buildStateFamilyConfig());
   return o;
 }
 
-checkUnnamed3086(core.List<api.StateFamilyConfig> o) {
+checkUnnamed3089(core.List<api.StateFamilyConfig> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStateFamilyConfig(o[0]);
   checkStateFamilyConfig(o[1]);
 }
 
 core.int buildCounterComputationTopology = 0;
 buildComputationTopology() {
   var o = new api.ComputationTopology();
   buildCounterComputationTopology++;
   if (buildCounterComputationTopology < 3) {
     o.computationId = "foo";
-    o.inputs = buildUnnamed3083();
-    o.keyRanges = buildUnnamed3084();
-    o.outputs = buildUnnamed3085();
-    o.stateFamilies = buildUnnamed3086();
+    o.inputs = buildUnnamed3086();
+    o.keyRanges = buildUnnamed3087();
+    o.outputs = buildUnnamed3088();
+    o.stateFamilies = buildUnnamed3089();
     o.systemStageName = "foo";
     o.userStageName = "foo";
   }
   buildCounterComputationTopology--;
   return o;
 }
 
 checkComputationTopology(api.ComputationTopology o) {
   buildCounterComputationTopology++;
   if (buildCounterComputationTopology < 3) {
     unittest.expect(o.computationId, unittest.equals('foo'));
-    checkUnnamed3083(o.inputs);
-    checkUnnamed3084(o.keyRanges);
-    checkUnnamed3085(o.outputs);
-    checkUnnamed3086(o.stateFamilies);
+    checkUnnamed3086(o.inputs);
+    checkUnnamed3087(o.keyRanges);
+    checkUnnamed3088(o.outputs);
+    checkUnnamed3089(o.stateFamilies);
     unittest.expect(o.systemStageName, unittest.equals('foo'));
     unittest.expect(o.userStageName, unittest.equals('foo'));
   }
   buildCounterComputationTopology--;
 }
 
 core.int buildCounterConcatPosition = 0;
 buildConcatPosition() {
   var o = new api.ConcatPosition();
   buildCounterConcatPosition++;
@@ skipping 131 matching lines @@
     checkIntegerMean(o.integerMean);
     var casted1 = (o.internal) as core.Map; unittest.expect(casted1, unittest.hasLength(3)); unittest.expect(casted1["list"], unittest.equals([1, 2, 3])); unittest.expect(casted1["bool"], unittest.equals(true)); unittest.expect(casted1["string"], unittest.equals('foo')); 
     checkNameAndKind(o.nameAndKind);
     unittest.expect(o.shortId, unittest.equals('foo'));
     checkStringList(o.stringList);
     checkCounterStructuredNameAndMetadata(o.structuredNameAndMetadata);
   }
   buildCounterCounterUpdate--;
 }
 
-buildUnnamed3087() {
+buildUnnamed3090() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3087(core.Map<core.String, core.String> o) {
+checkUnnamed3090(core.Map<core.String, core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o["x"], unittest.equals('foo'));
   unittest.expect(o["y"], unittest.equals('foo'));
 }
 
 core.int buildCounterCreateJobFromTemplateRequest = 0;
 buildCreateJobFromTemplateRequest() {
   var o = new api.CreateJobFromTemplateRequest();
   buildCounterCreateJobFromTemplateRequest++;
   if (buildCounterCreateJobFromTemplateRequest < 3) {
     o.environment = buildRuntimeEnvironment();
     o.gcsPath = "foo";
     o.jobName = "foo";
-    o.parameters = buildUnnamed3087();
+    o.location = "foo";
+    o.parameters = buildUnnamed3090();
   }
   buildCounterCreateJobFromTemplateRequest--;
   return o;
 }
 
 checkCreateJobFromTemplateRequest(api.CreateJobFromTemplateRequest o) {
   buildCounterCreateJobFromTemplateRequest++;
   if (buildCounterCreateJobFromTemplateRequest < 3) {
     checkRuntimeEnvironment(o.environment);
     unittest.expect(o.gcsPath, unittest.equals('foo'));
     unittest.expect(o.jobName, unittest.equals('foo'));
-    checkUnnamed3087(o.parameters);
+    unittest.expect(o.location, unittest.equals('foo'));
+    checkUnnamed3090(o.parameters);
   }
   buildCounterCreateJobFromTemplateRequest--;
 }
 
 core.int buildCounterCustomSourceLocation = 0;
 buildCustomSourceLocation() {
   var o = new api.CustomSourceLocation();
   buildCounterCustomSourceLocation++;
   if (buildCounterCustomSourceLocation < 3) {
     o.stateful = true;
   }
   buildCounterCustomSourceLocation--;
   return o;
 }
 
 checkCustomSourceLocation(api.CustomSourceLocation o) {
   buildCounterCustomSourceLocation++;
   if (buildCounterCustomSourceLocation < 3) {
     unittest.expect(o.stateful, unittest.isTrue);
   }
   buildCounterCustomSourceLocation--;
 }
 
-buildUnnamed3088() {
+buildUnnamed3091() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3088(core.List<core.String> o) {
+checkUnnamed3091(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
 core.int buildCounterDataDiskAssignment = 0;
 buildDataDiskAssignment() {
   var o = new api.DataDiskAssignment();
   buildCounterDataDiskAssignment++;
   if (buildCounterDataDiskAssignment < 3) {
-    o.dataDisks = buildUnnamed3088();
+    o.dataDisks = buildUnnamed3091();
     o.vmInstance = "foo";
   }
   buildCounterDataDiskAssignment--;
   return o;
 }
 
 checkDataDiskAssignment(api.DataDiskAssignment o) {
   buildCounterDataDiskAssignment++;
   if (buildCounterDataDiskAssignment < 3) {
-    checkUnnamed3088(o.dataDisks);
+    checkUnnamed3091(o.dataDisks);
     unittest.expect(o.vmInstance, unittest.equals('foo'));
   }
   buildCounterDataDiskAssignment--;
 }
 
 core.int buildCounterDerivedSource = 0;
 buildDerivedSource() {
   var o = new api.DerivedSource();
   buildCounterDerivedSource++;
   if (buildCounterDerivedSource < 3) {
@@ skipping 118 matching lines @@
 
 checkDynamicSourceSplit(api.DynamicSourceSplit o) {
   buildCounterDynamicSourceSplit++;
   if (buildCounterDynamicSourceSplit < 3) {
     checkDerivedSource(o.primary);
     checkDerivedSource(o.residual);
   }
   buildCounterDynamicSourceSplit--;
 }
 
-buildUnnamed3089() {
+buildUnnamed3092() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3089(core.List<core.String> o) {
+checkUnnamed3092(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
-buildUnnamed3090() {
-  var o = new core.Map<core.String, core.Object>();
-  o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
-  o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
-  return o;
-}
-
-checkUnnamed3090(core.Map<core.String, core.Object> o) {
-  unittest.expect(o, unittest.hasLength(2));
-  var casted2 = (o["x"]) as core.Map; unittest.expect(casted2, unittest.hasLength(3)); unittest.expect(casted2["list"], unittest.equals([1, 2, 3])); unittest.expect(casted2["bool"], unittest.equals(true)); unittest.expect(casted2["string"], unittest.equals('foo')); 
-  var casted3 = (o["y"]) as core.Map; unittest.expect(casted3, unittest.hasLength(3)); unittest.expect(casted3["list"], unittest.equals([1, 2, 3])); unittest.expect(casted3["bool"], unittest.equals(true)); unittest.expect(casted3["string"], unittest.equals('foo')); 
-}
-
-buildUnnamed3091() {
-  var o = new core.Map<core.String, core.Object>();
-  o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
-  o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
-  return o;
-}
-
-checkUnnamed3091(core.Map<core.String, core.Object> o) {
-  unittest.expect(o, unittest.hasLength(2));
-  var casted4 = (o["x"]) as core.Map; unittest.expect(casted4, unittest.hasLength(3)); unittest.expect(casted4["list"], unittest.equals([1, 2, 3])); unittest.expect(casted4["bool"], unittest.equals(true)); unittest.expect(casted4["string"], unittest.equals('foo')); 
-  var casted5 = (o["y"]) as core.Map; unittest.expect(casted5, unittest.hasLength(3)); unittest.expect(casted5["list"], unittest.equals([1, 2, 3])); unittest.expect(casted5["bool"], unittest.equals(true)); unittest.expect(casted5["string"], unittest.equals('foo')); 
-}
-
-buildUnnamed3092() {
-  var o = new core.Map<core.String, core.Object>();
-  o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
-  o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
-  return o;
-}
-
-checkUnnamed3092(core.Map<core.String, core.Object> o) {
-  unittest.expect(o, unittest.hasLength(2));
-  var casted6 = (o["x"]) as core.Map; unittest.expect(casted6, unittest.hasLength(3)); unittest.expect(casted6["list"], unittest.equals([1, 2, 3])); unittest.expect(casted6["bool"], unittest.equals(true)); unittest.expect(casted6["string"], unittest.equals('foo')); 
-  var casted7 = (o["y"]) as core.Map; unittest.expect(casted7, unittest.hasLength(3)); unittest.expect(casted7["list"], unittest.equals([1, 2, 3])); unittest.expect(casted7["bool"], unittest.equals(true)); unittest.expect(casted7["string"], unittest.equals('foo')); 
-}
-
 buildUnnamed3093() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
 checkUnnamed3093(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
+  var casted2 = (o["x"]) as core.Map; unittest.expect(casted2, unittest.hasLength(3)); unittest.expect(casted2["list"], unittest.equals([1, 2, 3])); unittest.expect(casted2["bool"], unittest.equals(true)); unittest.expect(casted2["string"], unittest.equals('foo')); 
+  var casted3 = (o["y"]) as core.Map; unittest.expect(casted3, unittest.hasLength(3)); unittest.expect(casted3["list"], unittest.equals([1, 2, 3])); unittest.expect(casted3["bool"], unittest.equals(true)); unittest.expect(casted3["string"], unittest.equals('foo')); 
+}
+
+buildUnnamed3094() {
+  var o = new core.Map<core.String, core.Object>();
+  o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
+  o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
+  return o;
+}
+
+checkUnnamed3094(core.Map<core.String, core.Object> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  var casted4 = (o["x"]) as core.Map; unittest.expect(casted4, unittest.hasLength(3)); unittest.expect(casted4["list"], unittest.equals([1, 2, 3])); unittest.expect(casted4["bool"], unittest.equals(true)); unittest.expect(casted4["string"], unittest.equals('foo')); 
+  var casted5 = (o["y"]) as core.Map; unittest.expect(casted5, unittest.hasLength(3)); unittest.expect(casted5["list"], unittest.equals([1, 2, 3])); unittest.expect(casted5["bool"], unittest.equals(true)); unittest.expect(casted5["string"], unittest.equals('foo')); 
+}
+
+buildUnnamed3095() {
+  var o = new core.Map<core.String, core.Object>();
+  o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
+  o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
+  return o;
+}
+
+checkUnnamed3095(core.Map<core.String, core.Object> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  var casted6 = (o["x"]) as core.Map; unittest.expect(casted6, unittest.hasLength(3)); unittest.expect(casted6["list"], unittest.equals([1, 2, 3])); unittest.expect(casted6["bool"], unittest.equals(true)); unittest.expect(casted6["string"], unittest.equals('foo')); 
+  var casted7 = (o["y"]) as core.Map; unittest.expect(casted7, unittest.hasLength(3)); unittest.expect(casted7["list"], unittest.equals([1, 2, 3])); unittest.expect(casted7["bool"], unittest.equals(true)); unittest.expect(casted7["string"], unittest.equals('foo')); 
+}
+
+buildUnnamed3096() {
+  var o = new core.Map<core.String, core.Object>();
+  o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
+  o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
+  return o;
+}
+
+checkUnnamed3096(core.Map<core.String, core.Object> o) {
+  unittest.expect(o, unittest.hasLength(2));
   var casted8 = (o["x"]) as core.Map; unittest.expect(casted8, unittest.hasLength(3)); unittest.expect(casted8["list"], unittest.equals([1, 2, 3])); unittest.expect(casted8["bool"], unittest.equals(true)); unittest.expect(casted8["string"], unittest.equals('foo')); 
   var casted9 = (o["y"]) as core.Map; unittest.expect(casted9, unittest.hasLength(3)); unittest.expect(casted9["list"], unittest.equals([1, 2, 3])); unittest.expect(casted9["bool"], unittest.equals(true)); unittest.expect(casted9["string"], unittest.equals('foo')); 
 }
 
-buildUnnamed3094() {
+buildUnnamed3097() {
   var o = new core.List<api.WorkerPool>();
   o.add(buildWorkerPool());
   o.add(buildWorkerPool());
   return o;
 }
 
-checkUnnamed3094(core.List<api.WorkerPool> o) {
+checkUnnamed3097(core.List<api.WorkerPool> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkerPool(o[0]);
   checkWorkerPool(o[1]);
 }
 
 core.int buildCounterEnvironment = 0;
 buildEnvironment() {
   var o = new api.Environment();
   buildCounterEnvironment++;
   if (buildCounterEnvironment < 3) {
     o.clusterManagerApiService = "foo";
     o.dataset = "foo";
-    o.experiments = buildUnnamed3089();
-    o.internalExperiments = buildUnnamed3090();
-    o.sdkPipelineOptions = buildUnnamed3091();
+    o.experiments = buildUnnamed3092();
+    o.internalExperiments = buildUnnamed3093();
+    o.sdkPipelineOptions = buildUnnamed3094();
     o.serviceAccountEmail = "foo";
     o.tempStoragePrefix = "foo";
-    o.userAgent = buildUnnamed3092();
-    o.version = buildUnnamed3093();
-    o.workerPools = buildUnnamed3094();
+    o.userAgent = buildUnnamed3095();
+    o.version = buildUnnamed3096();
+    o.workerPools = buildUnnamed3097();
   }
   buildCounterEnvironment--;
   return o;
 }
 
 checkEnvironment(api.Environment o) {
   buildCounterEnvironment++;
   if (buildCounterEnvironment < 3) {
     unittest.expect(o.clusterManagerApiService, unittest.equals('foo'));
     unittest.expect(o.dataset, unittest.equals('foo'));
-    checkUnnamed3089(o.experiments);
-    checkUnnamed3090(o.internalExperiments);
-    checkUnnamed3091(o.sdkPipelineOptions);
+    checkUnnamed3092(o.experiments);
+    checkUnnamed3093(o.internalExperiments);
+    checkUnnamed3094(o.sdkPipelineOptions);
     unittest.expect(o.serviceAccountEmail, unittest.equals('foo'));
     unittest.expect(o.tempStoragePrefix, unittest.equals('foo'));
-    checkUnnamed3092(o.userAgent);
-    checkUnnamed3093(o.version);
-    checkUnnamed3094(o.workerPools);
+    checkUnnamed3095(o.userAgent);
+    checkUnnamed3096(o.version);
+    checkUnnamed3097(o.workerPools);
   }
   buildCounterEnvironment--;
 }
 
-buildUnnamed3095() {
+core.int buildCounterExecutionStageState = 0;
+buildExecutionStageState() {
+  var o = new api.ExecutionStageState();
+  buildCounterExecutionStageState++;
+  if (buildCounterExecutionStageState < 3) {
+    o.currentStateTime = "foo";
+    o.executionStageName = "foo";
+    o.executionStageState = "foo";
+  }
+  buildCounterExecutionStageState--;
+  return o;
+}
+
+checkExecutionStageState(api.ExecutionStageState o) {
+  buildCounterExecutionStageState++;
+  if (buildCounterExecutionStageState < 3) {
+    unittest.expect(o.currentStateTime, unittest.equals('foo'));
+    unittest.expect(o.executionStageName, unittest.equals('foo'));
+    unittest.expect(o.executionStageState, unittest.equals('foo'));
+  }
+  buildCounterExecutionStageState--;
+}
+
+buildUnnamed3098() {
   var o = new core.List<api.ComponentSource>();
   o.add(buildComponentSource());
   o.add(buildComponentSource());
   return o;
 }
 
-checkUnnamed3095(core.List<api.ComponentSource> o) {
+checkUnnamed3098(core.List<api.ComponentSource> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkComponentSource(o[0]);
   checkComponentSource(o[1]);
 }
 
-buildUnnamed3096() {
+buildUnnamed3099() {
   var o = new core.List<api.ComponentTransform>();
   o.add(buildComponentTransform());
   o.add(buildComponentTransform());
   return o;
 }
 
-checkUnnamed3096(core.List<api.ComponentTransform> o) {
+checkUnnamed3099(core.List<api.ComponentTransform> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkComponentTransform(o[0]);
   checkComponentTransform(o[1]);
 }
 
-buildUnnamed3097() {
+buildUnnamed3100() {
   var o = new core.List<api.StageSource>();
   o.add(buildStageSource());
   o.add(buildStageSource());
   return o;
 }
 
-checkUnnamed3097(core.List<api.StageSource> o) {
+checkUnnamed3100(core.List<api.StageSource> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStageSource(o[0]);
   checkStageSource(o[1]);
 }
 
-buildUnnamed3098() {
+buildUnnamed3101() {
   var o = new core.List<api.StageSource>();
   o.add(buildStageSource());
   o.add(buildStageSource());
   return o;
 }
 
-checkUnnamed3098(core.List<api.StageSource> o) {
+checkUnnamed3101(core.List<api.StageSource> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStageSource(o[0]);
   checkStageSource(o[1]);
 }
 
 core.int buildCounterExecutionStageSummary = 0;
 buildExecutionStageSummary() {
   var o = new api.ExecutionStageSummary();
   buildCounterExecutionStageSummary++;
   if (buildCounterExecutionStageSummary < 3) {
-    o.componentSource = buildUnnamed3095();
-    o.componentTransform = buildUnnamed3096();
+    o.componentSource = buildUnnamed3098();
+    o.componentTransform = buildUnnamed3099();
     o.id = "foo";
-    o.inputSource = buildUnnamed3097();
+    o.inputSource = buildUnnamed3100();
     o.kind = "foo";
     o.name = "foo";
-    o.outputSource = buildUnnamed3098();
+    o.outputSource = buildUnnamed3101();
   }
   buildCounterExecutionStageSummary--;
   return o;
 }
 
 checkExecutionStageSummary(api.ExecutionStageSummary o) {
   buildCounterExecutionStageSummary++;
   if (buildCounterExecutionStageSummary < 3) {
-    checkUnnamed3095(o.componentSource);
-    checkUnnamed3096(o.componentTransform);
+    checkUnnamed3098(o.componentSource);
+    checkUnnamed3099(o.componentTransform);
     unittest.expect(o.id, unittest.equals('foo'));
-    checkUnnamed3097(o.inputSource);
+    checkUnnamed3100(o.inputSource);
     unittest.expect(o.kind, unittest.equals('foo'));
     unittest.expect(o.name, unittest.equals('foo'));
-    checkUnnamed3098(o.outputSource);
+    checkUnnamed3101(o.outputSource);
   }
   buildCounterExecutionStageSummary--;
 }
 
 core.int buildCounterFailedLocation = 0;
 buildFailedLocation() {
   var o = new api.FailedLocation();
   buildCounterFailedLocation++;
   if (buildCounterFailedLocation < 3) {
     o.name = "foo";
   }
   buildCounterFailedLocation--;
   return o;
 }
 
 checkFailedLocation(api.FailedLocation o) {
   buildCounterFailedLocation++;
   if (buildCounterFailedLocation < 3) {
     unittest.expect(o.name, unittest.equals('foo'));
   }
   buildCounterFailedLocation--;
 }
 
-buildUnnamed3099() {
+buildUnnamed3102() {
   var o = new core.List<api.InstructionInput>();
   o.add(buildInstructionInput());
   o.add(buildInstructionInput());
   return o;
 }
 
-checkUnnamed3099(core.List<api.InstructionInput> o) {
+checkUnnamed3102(core.List<api.InstructionInput> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkInstructionInput(o[0]);
   checkInstructionInput(o[1]);
 }
 
 core.int buildCounterFlattenInstruction = 0;
 buildFlattenInstruction() {
   var o = new api.FlattenInstruction();
   buildCounterFlattenInstruction++;
   if (buildCounterFlattenInstruction < 3) {
-    o.inputs = buildUnnamed3099();
+    o.inputs = buildUnnamed3102();
   }
   buildCounterFlattenInstruction--;
   return o;
 }
 
 checkFlattenInstruction(api.FlattenInstruction o) {
   buildCounterFlattenInstruction++;
   if (buildCounterFlattenInstruction < 3) {
-    checkUnnamed3099(o.inputs);
+    checkUnnamed3102(o.inputs);
   }
   buildCounterFlattenInstruction--;
 }
 
-buildUnnamed3100() {
+buildUnnamed3103() {
   var o = new core.List<core.double>();
   o.add(42.0);
   o.add(42.0);
   return o;
 }
 
-checkUnnamed3100(core.List<core.double> o) {
+checkUnnamed3103(core.List<core.double> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals(42.0));
   unittest.expect(o[1], unittest.equals(42.0));
 }
 
 core.int buildCounterFloatingPointList = 0;
 buildFloatingPointList() {
   var o = new api.FloatingPointList();
   buildCounterFloatingPointList++;
   if (buildCounterFloatingPointList < 3) {
-    o.elements = buildUnnamed3100();
+    o.elements = buildUnnamed3103();
   }
   buildCounterFloatingPointList--;
   return o;
 }
 
 checkFloatingPointList(api.FloatingPointList o) {
   buildCounterFloatingPointList++;
   if (buildCounterFloatingPointList < 3) {
-    checkUnnamed3100(o.elements);
+    checkUnnamed3103(o.elements);
   }
   buildCounterFloatingPointList--;
 }
 
 core.int buildCounterFloatingPointMean = 0;
 buildFloatingPointMean() {
   var o = new api.FloatingPointMean();
   buildCounterFloatingPointMean++;
   if (buildCounterFloatingPointMean < 3) {
     o.count = buildSplitInt64();
@@ skipping 11 matching lines @@
   }
   buildCounterFloatingPointMean--;
 }
 
 core.int buildCounterGetDebugConfigRequest = 0;
 buildGetDebugConfigRequest() {
   var o = new api.GetDebugConfigRequest();
   buildCounterGetDebugConfigRequest++;
   if (buildCounterGetDebugConfigRequest < 3) {
     o.componentId = "foo";
+    o.location = "foo";
     o.workerId = "foo";
   }
   buildCounterGetDebugConfigRequest--;
   return o;
 }
 
 checkGetDebugConfigRequest(api.GetDebugConfigRequest o) {
   buildCounterGetDebugConfigRequest++;
   if (buildCounterGetDebugConfigRequest < 3) {
     unittest.expect(o.componentId, unittest.equals('foo'));
+    unittest.expect(o.location, unittest.equals('foo'));
     unittest.expect(o.workerId, unittest.equals('foo'));
   }
   buildCounterGetDebugConfigRequest--;
 }
 
 core.int buildCounterGetDebugConfigResponse = 0;
 buildGetDebugConfigResponse() {
   var o = new api.GetDebugConfigResponse();
   buildCounterGetDebugConfigResponse++;
   if (buildCounterGetDebugConfigResponse < 3) {
@@ skipping 46 matching lines @@
 
 checkInstructionInput(api.InstructionInput o) {
   buildCounterInstructionInput++;
   if (buildCounterInstructionInput < 3) {
     unittest.expect(o.outputNum, unittest.equals(42));
     unittest.expect(o.producerInstructionIndex, unittest.equals(42));
   }
   buildCounterInstructionInput--;
 }
 
-buildUnnamed3101() {
+buildUnnamed3104() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3101(core.Map<core.String, core.Object> o) {
+checkUnnamed3104(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
   var casted10 = (o["x"]) as core.Map; unittest.expect(casted10, unittest.hasLength(3)); unittest.expect(casted10["list"], unittest.equals([1, 2, 3])); unittest.expect(casted10["bool"], unittest.equals(true)); unittest.expect(casted10["string"], unittest.equals('foo')); 
   var casted11 = (o["y"]) as core.Map; unittest.expect(casted11, unittest.hasLength(3)); unittest.expect(casted11["list"], unittest.equals([1, 2, 3])); unittest.expect(casted11["bool"], unittest.equals(true)); unittest.expect(casted11["string"], unittest.equals('foo')); 
 }
 
 core.int buildCounterInstructionOutput = 0;
 buildInstructionOutput() {
   var o = new api.InstructionOutput();
   buildCounterInstructionOutput++;
   if (buildCounterInstructionOutput < 3) {
-    o.codec = buildUnnamed3101();
+    o.codec = buildUnnamed3104();
     o.name = "foo";
     o.onlyCountKeyBytes = true;
     o.onlyCountValueBytes = true;
     o.originalName = "foo";
     o.systemName = "foo";
   }
   buildCounterInstructionOutput--;
   return o;
 }
 
 checkInstructionOutput(api.InstructionOutput o) {
   buildCounterInstructionOutput++;
   if (buildCounterInstructionOutput < 3) {
-    checkUnnamed3101(o.codec);
+    checkUnnamed3104(o.codec);
     unittest.expect(o.name, unittest.equals('foo'));
     unittest.expect(o.onlyCountKeyBytes, unittest.isTrue);
     unittest.expect(o.onlyCountValueBytes, unittest.isTrue);
     unittest.expect(o.originalName, unittest.equals('foo'));
     unittest.expect(o.systemName, unittest.equals('foo'));
   }
   buildCounterInstructionOutput--;
 }
 
-buildUnnamed3102() {
+buildUnnamed3105() {
   var o = new core.List<api.SplitInt64>();
   o.add(buildSplitInt64());
   o.add(buildSplitInt64());
   return o;
 }
 
-checkUnnamed3102(core.List<api.SplitInt64> o) {
+checkUnnamed3105(core.List<api.SplitInt64> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSplitInt64(o[0]);
   checkSplitInt64(o[1]);
 }
 
 core.int buildCounterIntegerList = 0;
 buildIntegerList() {
   var o = new api.IntegerList();
   buildCounterIntegerList++;
   if (buildCounterIntegerList < 3) {
-    o.elements = buildUnnamed3102();
+    o.elements = buildUnnamed3105();
   }
   buildCounterIntegerList--;
   return o;
 }
 
 checkIntegerList(api.IntegerList o) {
   buildCounterIntegerList++;
   if (buildCounterIntegerList < 3) {
-    checkUnnamed3102(o.elements);
+    checkUnnamed3105(o.elements);
   }
   buildCounterIntegerList--;
 }
 
 core.int buildCounterIntegerMean = 0;
 buildIntegerMean() {
   var o = new api.IntegerMean();
   buildCounterIntegerMean++;
   if (buildCounterIntegerMean < 3) {
     o.count = buildSplitInt64();
     o.sum = buildSplitInt64();
   }
   buildCounterIntegerMean--;
   return o;
 }
 
 checkIntegerMean(api.IntegerMean o) {
   buildCounterIntegerMean++;
   if (buildCounterIntegerMean < 3) {
     checkSplitInt64(o.count);
     checkSplitInt64(o.sum);
   }
   buildCounterIntegerMean--;
 }
 
-buildUnnamed3103() {
-  var o = new core.Map<core.String, core.String>();
-  o["x"] = "foo";
-  o["y"] = "foo";
-  return o;
-}
-
-checkUnnamed3103(core.Map<core.String, core.String> o) {
-  unittest.expect(o, unittest.hasLength(2));
-  unittest.expect(o["x"], unittest.equals('foo'));
-  unittest.expect(o["y"], unittest.equals('foo'));
-}
-
-buildUnnamed3104() {
-  var o = new core.List<api.Step>();
-  o.add(buildStep());
-  o.add(buildStep());
-  return o;
-}
-
-checkUnnamed3104(core.List<api.Step> o) {
-  unittest.expect(o, unittest.hasLength(2));
-  checkStep(o[0]);
-  checkStep(o[1]);
-}
-
-buildUnnamed3105() {
-  var o = new core.List<core.String>();
-  o.add("foo");
-  o.add("foo");
-  return o;
-}
-
-checkUnnamed3105(core.List<core.String> o) {
-  unittest.expect(o, unittest.hasLength(2));
-  unittest.expect(o[0], unittest.equals('foo'));
-  unittest.expect(o[1], unittest.equals('foo'));
-}
-
 buildUnnamed3106() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
 checkUnnamed3106(core.Map<core.String, core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o["x"], unittest.equals('foo'));
   unittest.expect(o["y"], unittest.equals('foo'));
+}
+
+buildUnnamed3107() {
+  var o = new core.List<api.ExecutionStageState>();
+  o.add(buildExecutionStageState());
+  o.add(buildExecutionStageState());
+  return o;
+}
+
+checkUnnamed3107(core.List<api.ExecutionStageState> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  checkExecutionStageState(o[0]);
+  checkExecutionStageState(o[1]);
+}
+
+buildUnnamed3108() {
+  var o = new core.List<api.Step>();
+  o.add(buildStep());
+  o.add(buildStep());
+  return o;
+}
+
+checkUnnamed3108(core.List<api.Step> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  checkStep(o[0]);
+  checkStep(o[1]);
+}
+
+buildUnnamed3109() {
+  var o = new core.List<core.String>();
+  o.add("foo");
+  o.add("foo");
+  return o;
+}
+
+checkUnnamed3109(core.List<core.String> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  unittest.expect(o[0], unittest.equals('foo'));
+  unittest.expect(o[1], unittest.equals('foo'));
+}
+
+buildUnnamed3110() {
+  var o = new core.Map<core.String, core.String>();
+  o["x"] = "foo";
+  o["y"] = "foo";
+  return o;
+}
+
+checkUnnamed3110(core.Map<core.String, core.String> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  unittest.expect(o["x"], unittest.equals('foo'));
+  unittest.expect(o["y"], unittest.equals('foo'));
 }
 
 core.int buildCounterJob = 0;
 buildJob() {
   var o = new api.Job();
   buildCounterJob++;
   if (buildCounterJob < 3) {
     o.clientRequestId = "foo";
     o.createTime = "foo";
     o.currentState = "foo";
     o.currentStateTime = "foo";
     o.environment = buildEnvironment();
     o.executionInfo = buildJobExecutionInfo();
     o.id = "foo";
-    o.labels = buildUnnamed3103();
+    o.labels = buildUnnamed3106();
     o.location = "foo";
     o.name = "foo";
     o.pipelineDescription = buildPipelineDescription();
     o.projectId = "foo";
     o.replaceJobId = "foo";
     o.replacedByJobId = "foo";
     o.requestedState = "foo";
-    o.steps = buildUnnamed3104();
-    o.tempFiles = buildUnnamed3105();
-    o.transformNameMapping = buildUnnamed3106();
+    o.stageStates = buildUnnamed3107();
+    o.steps = buildUnnamed3108();
+    o.tempFiles = buildUnnamed3109();
+    o.transformNameMapping = buildUnnamed3110();
     o.type = "foo";
   }
   buildCounterJob--;
   return o;
 }
 
 checkJob(api.Job o) {
   buildCounterJob++;
   if (buildCounterJob < 3) {
     unittest.expect(o.clientRequestId, unittest.equals('foo'));
     unittest.expect(o.createTime, unittest.equals('foo'));
     unittest.expect(o.currentState, unittest.equals('foo'));
     unittest.expect(o.currentStateTime, unittest.equals('foo'));
     checkEnvironment(o.environment);
     checkJobExecutionInfo(o.executionInfo);
     unittest.expect(o.id, unittest.equals('foo'));
-    checkUnnamed3103(o.labels);
+    checkUnnamed3106(o.labels);
     unittest.expect(o.location, unittest.equals('foo'));
     unittest.expect(o.name, unittest.equals('foo'));
     checkPipelineDescription(o.pipelineDescription);
     unittest.expect(o.projectId, unittest.equals('foo'));
     unittest.expect(o.replaceJobId, unittest.equals('foo'));
     unittest.expect(o.replacedByJobId, unittest.equals('foo'));
     unittest.expect(o.requestedState, unittest.equals('foo'));
-    checkUnnamed3104(o.steps);
-    checkUnnamed3105(o.tempFiles);
-    checkUnnamed3106(o.transformNameMapping);
+    checkUnnamed3107(o.stageStates);
+    checkUnnamed3108(o.steps);
+    checkUnnamed3109(o.tempFiles);
+    checkUnnamed3110(o.transformNameMapping);
     unittest.expect(o.type, unittest.equals('foo'));
   }
   buildCounterJob--;
 }
 
-buildUnnamed3107() {
+buildUnnamed3111() {
   var o = new core.Map<core.String, api.JobExecutionStageInfo>();
   o["x"] = buildJobExecutionStageInfo();
   o["y"] = buildJobExecutionStageInfo();
   return o;
 }
 
-checkUnnamed3107(core.Map<core.String, api.JobExecutionStageInfo> o) {
+checkUnnamed3111(core.Map<core.String, api.JobExecutionStageInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkJobExecutionStageInfo(o["x"]);
   checkJobExecutionStageInfo(o["y"]);
 }
 
 core.int buildCounterJobExecutionInfo = 0;
 buildJobExecutionInfo() {
   var o = new api.JobExecutionInfo();
   buildCounterJobExecutionInfo++;
   if (buildCounterJobExecutionInfo < 3) {
-    o.stages = buildUnnamed3107();
+    o.stages = buildUnnamed3111();
   }
   buildCounterJobExecutionInfo--;
   return o;
 }
 
 checkJobExecutionInfo(api.JobExecutionInfo o) {
   buildCounterJobExecutionInfo++;
   if (buildCounterJobExecutionInfo < 3) {
-    checkUnnamed3107(o.stages);
+    checkUnnamed3111(o.stages);
   }
   buildCounterJobExecutionInfo--;
 }
 
-buildUnnamed3108() {
+buildUnnamed3112() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3108(core.List<core.String> o) {
+checkUnnamed3112(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
 core.int buildCounterJobExecutionStageInfo = 0;
 buildJobExecutionStageInfo() {
   var o = new api.JobExecutionStageInfo();
   buildCounterJobExecutionStageInfo++;
   if (buildCounterJobExecutionStageInfo < 3) {
-    o.stepName = buildUnnamed3108();
+    o.stepName = buildUnnamed3112();
   }
   buildCounterJobExecutionStageInfo--;
   return o;
 }
 
 checkJobExecutionStageInfo(api.JobExecutionStageInfo o) {
   buildCounterJobExecutionStageInfo++;
   if (buildCounterJobExecutionStageInfo < 3) {
-    checkUnnamed3108(o.stepName);
+    checkUnnamed3112(o.stepName);
   }
   buildCounterJobExecutionStageInfo--;
 }
 
 core.int buildCounterJobMessage = 0;
 buildJobMessage() {
   var o = new api.JobMessage();
   buildCounterJobMessage++;
   if (buildCounterJobMessage < 3) {
     o.id = "foo";
     o.messageImportance = "foo";
     o.messageText = "foo";
     o.time = "foo";
   }
   buildCounterJobMessage--;
   return o;
 }
 
 checkJobMessage(api.JobMessage o) {
   buildCounterJobMessage++;
   if (buildCounterJobMessage < 3) {
     unittest.expect(o.id, unittest.equals('foo'));
     unittest.expect(o.messageImportance, unittest.equals('foo'));
     unittest.expect(o.messageText, unittest.equals('foo'));
     unittest.expect(o.time, unittest.equals('foo'));
   }
   buildCounterJobMessage--;
 }
 
-buildUnnamed3109() {
+buildUnnamed3113() {
   var o = new core.List<api.MetricUpdate>();
   o.add(buildMetricUpdate());
   o.add(buildMetricUpdate());
   return o;
 }
 
-checkUnnamed3109(core.List<api.MetricUpdate> o) {
+checkUnnamed3113(core.List<api.MetricUpdate> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkMetricUpdate(o[0]);
   checkMetricUpdate(o[1]);
 }
 
 core.int buildCounterJobMetrics = 0;
 buildJobMetrics() {
   var o = new api.JobMetrics();
   buildCounterJobMetrics++;
   if (buildCounterJobMetrics < 3) {
     o.metricTime = "foo";
-    o.metrics = buildUnnamed3109();
+    o.metrics = buildUnnamed3113();
   }
   buildCounterJobMetrics--;
   return o;
 }
 
 checkJobMetrics(api.JobMetrics o) {
   buildCounterJobMetrics++;
   if (buildCounterJobMetrics < 3) {
     unittest.expect(o.metricTime, unittest.equals('foo'));
-    checkUnnamed3109(o.metrics);
+    checkUnnamed3113(o.metrics);
   }
   buildCounterJobMetrics--;
 }
 
 core.int buildCounterKeyRangeDataDiskAssignment = 0;
 buildKeyRangeDataDiskAssignment() {
   var o = new api.KeyRangeDataDiskAssignment();
   buildCounterKeyRangeDataDiskAssignment++;
   if (buildCounterKeyRangeDataDiskAssignment < 3) {
     o.dataDisk = "foo";
@@ skipping 34 matching lines @@
   if (buildCounterKeyRangeLocation < 3) {
     unittest.expect(o.dataDisk, unittest.equals('foo'));
     unittest.expect(o.deliveryEndpoint, unittest.equals('foo'));
     unittest.expect(o.deprecatedPersistentDirectory, unittest.equals('foo'));
     unittest.expect(o.end, unittest.equals('foo'));
     unittest.expect(o.start, unittest.equals('foo'));
   }
   buildCounterKeyRangeLocation--;
 }
 
-buildUnnamed3110() {
+buildUnnamed3114() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3110(core.Map<core.String, core.String> o) {
+checkUnnamed3114(core.Map<core.String, core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o["x"], unittest.equals('foo'));
   unittest.expect(o["y"], unittest.equals('foo'));
 }
 
 core.int buildCounterLaunchTemplateParameters = 0;
 buildLaunchTemplateParameters() {
   var o = new api.LaunchTemplateParameters();
   buildCounterLaunchTemplateParameters++;
   if (buildCounterLaunchTemplateParameters < 3) {
     o.environment = buildRuntimeEnvironment();
     o.jobName = "foo";
-    o.parameters = buildUnnamed3110();
+    o.parameters = buildUnnamed3114();
   }
   buildCounterLaunchTemplateParameters--;
   return o;
 }
 
 checkLaunchTemplateParameters(api.LaunchTemplateParameters o) {
   buildCounterLaunchTemplateParameters++;
   if (buildCounterLaunchTemplateParameters < 3) {
     checkRuntimeEnvironment(o.environment);
     unittest.expect(o.jobName, unittest.equals('foo'));
-    checkUnnamed3110(o.parameters);
+    checkUnnamed3114(o.parameters);
   }
   buildCounterLaunchTemplateParameters--;
 }
 
 core.int buildCounterLaunchTemplateResponse = 0;
 buildLaunchTemplateResponse() {
   var o = new api.LaunchTemplateResponse();
   buildCounterLaunchTemplateResponse++;
   if (buildCounterLaunchTemplateResponse < 3) {
     o.job = buildJob();
   }
   buildCounterLaunchTemplateResponse--;
   return o;
 }
 
 checkLaunchTemplateResponse(api.LaunchTemplateResponse o) {
   buildCounterLaunchTemplateResponse++;
   if (buildCounterLaunchTemplateResponse < 3) {
     checkJob(o.job);
   }
   buildCounterLaunchTemplateResponse--;
 }
 
-buildUnnamed3111() {
+buildUnnamed3115() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3111(core.List<core.String> o) {
+checkUnnamed3115(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
-buildUnnamed3112() {
+buildUnnamed3116() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3112(core.List<core.String> o) {
+checkUnnamed3116(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
 core.int buildCounterLeaseWorkItemRequest = 0;
 buildLeaseWorkItemRequest() {
   var o = new api.LeaseWorkItemRequest();
   buildCounterLeaseWorkItemRequest++;
   if (buildCounterLeaseWorkItemRequest < 3) {
     o.currentWorkerTime = "foo";
     o.location = "foo";
     o.requestedLeaseDuration = "foo";
-    o.workItemTypes = buildUnnamed3111();
-    o.workerCapabilities = buildUnnamed3112();
+    o.workItemTypes = buildUnnamed3115();
+    o.workerCapabilities = buildUnnamed3116();
     o.workerId = "foo";
   }
   buildCounterLeaseWorkItemRequest--;
   return o;
 }
 
 checkLeaseWorkItemRequest(api.LeaseWorkItemRequest o) {
   buildCounterLeaseWorkItemRequest++;
   if (buildCounterLeaseWorkItemRequest < 3) {
     unittest.expect(o.currentWorkerTime, unittest.equals('foo'));
     unittest.expect(o.location, unittest.equals('foo'));
     unittest.expect(o.requestedLeaseDuration, unittest.equals('foo'));
-    checkUnnamed3111(o.workItemTypes);
-    checkUnnamed3112(o.workerCapabilities);
+    checkUnnamed3115(o.workItemTypes);
+    checkUnnamed3116(o.workerCapabilities);
     unittest.expect(o.workerId, unittest.equals('foo'));
   }
   buildCounterLeaseWorkItemRequest--;
 }
 
-buildUnnamed3113() {
+buildUnnamed3117() {
   var o = new core.List<api.WorkItem>();
   o.add(buildWorkItem());
   o.add(buildWorkItem());
   return o;
 }
 
-checkUnnamed3113(core.List<api.WorkItem> o) {
+checkUnnamed3117(core.List<api.WorkItem> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkItem(o[0]);
   checkWorkItem(o[1]);
 }
 
 core.int buildCounterLeaseWorkItemResponse = 0;
 buildLeaseWorkItemResponse() {
   var o = new api.LeaseWorkItemResponse();
   buildCounterLeaseWorkItemResponse++;
   if (buildCounterLeaseWorkItemResponse < 3) {
-    o.workItems = buildUnnamed3113();
+    o.workItems = buildUnnamed3117();
   }
   buildCounterLeaseWorkItemResponse--;
   return o;
 }
 
 checkLeaseWorkItemResponse(api.LeaseWorkItemResponse o) {
   buildCounterLeaseWorkItemResponse++;
   if (buildCounterLeaseWorkItemResponse < 3) {
-    checkUnnamed3113(o.workItems);
+    checkUnnamed3117(o.workItems);
   }
   buildCounterLeaseWorkItemResponse--;
 }
 
-buildUnnamed3114() {
+buildUnnamed3118() {
+  var o = new core.List<api.AutoscalingEvent>();
+  o.add(buildAutoscalingEvent());
+  o.add(buildAutoscalingEvent());
+  return o;
+}
+
+checkUnnamed3118(core.List<api.AutoscalingEvent> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  checkAutoscalingEvent(o[0]);
+  checkAutoscalingEvent(o[1]);
+}
+
+buildUnnamed3119() {
   var o = new core.List<api.JobMessage>();
   o.add(buildJobMessage());
   o.add(buildJobMessage());
   return o;
 }
 
-checkUnnamed3114(core.List<api.JobMessage> o) {
+checkUnnamed3119(core.List<api.JobMessage> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkJobMessage(o[0]);
   checkJobMessage(o[1]);
 }
 
 core.int buildCounterListJobMessagesResponse = 0;
 buildListJobMessagesResponse() {
   var o = new api.ListJobMessagesResponse();
   buildCounterListJobMessagesResponse++;
   if (buildCounterListJobMessagesResponse < 3) {
-    o.jobMessages = buildUnnamed3114();
+    o.autoscalingEvents = buildUnnamed3118();
+    o.jobMessages = buildUnnamed3119();
     o.nextPageToken = "foo";
   }
   buildCounterListJobMessagesResponse--;
   return o;
 }
 
 checkListJobMessagesResponse(api.ListJobMessagesResponse o) {
   buildCounterListJobMessagesResponse++;
   if (buildCounterListJobMessagesResponse < 3) {
-    checkUnnamed3114(o.jobMessages);
+    checkUnnamed3118(o.autoscalingEvents);
+    checkUnnamed3119(o.jobMessages);
     unittest.expect(o.nextPageToken, unittest.equals('foo'));
   }
   buildCounterListJobMessagesResponse--;
 }
 
-buildUnnamed3115() {
+buildUnnamed3120() {
   var o = new core.List<api.FailedLocation>();
   o.add(buildFailedLocation());
   o.add(buildFailedLocation());
   return o;
 }
 
-checkUnnamed3115(core.List<api.FailedLocation> o) {
+checkUnnamed3120(core.List<api.FailedLocation> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkFailedLocation(o[0]);
   checkFailedLocation(o[1]);
 }
 
-buildUnnamed3116() {
+buildUnnamed3121() {
   var o = new core.List<api.Job>();
   o.add(buildJob());
   o.add(buildJob());
   return o;
 }
 
-checkUnnamed3116(core.List<api.Job> o) {
+checkUnnamed3121(core.List<api.Job> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkJob(o[0]);
   checkJob(o[1]);
 }
 
 core.int buildCounterListJobsResponse = 0;
 buildListJobsResponse() {
   var o = new api.ListJobsResponse();
   buildCounterListJobsResponse++;
   if (buildCounterListJobsResponse < 3) {
-    o.failedLocation = buildUnnamed3115();
-    o.jobs = buildUnnamed3116();
+    o.failedLocation = buildUnnamed3120();
+    o.jobs = buildUnnamed3121();
     o.nextPageToken = "foo";
   }
   buildCounterListJobsResponse--;
   return o;
 }
 
 checkListJobsResponse(api.ListJobsResponse o) {
   buildCounterListJobsResponse++;
   if (buildCounterListJobsResponse < 3) {
-    checkUnnamed3115(o.failedLocation);
-    checkUnnamed3116(o.jobs);
+    checkUnnamed3120(o.failedLocation);
+    checkUnnamed3121(o.jobs);
     unittest.expect(o.nextPageToken, unittest.equals('foo'));
   }
   buildCounterListJobsResponse--;
 }
 
-buildUnnamed3117() {
+buildUnnamed3122() {
   var o = new core.List<api.ParallelInstruction>();
   o.add(buildParallelInstruction());
   o.add(buildParallelInstruction());
   return o;
 }
 
-checkUnnamed3117(core.List<api.ParallelInstruction> o) {
+checkUnnamed3122(core.List<api.ParallelInstruction> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkParallelInstruction(o[0]);
   checkParallelInstruction(o[1]);
 }
 
 core.int buildCounterMapTask = 0;
 buildMapTask() {
   var o = new api.MapTask();
   buildCounterMapTask++;
   if (buildCounterMapTask < 3) {
-    o.instructions = buildUnnamed3117();
+    o.instructions = buildUnnamed3122();
     o.stageName = "foo";
     o.systemName = "foo";
   }
   buildCounterMapTask--;
   return o;
 }
 
 checkMapTask(api.MapTask o) {
   buildCounterMapTask++;
   if (buildCounterMapTask < 3) {
-    checkUnnamed3117(o.instructions);
+    checkUnnamed3122(o.instructions);
     unittest.expect(o.stageName, unittest.equals('foo'));
     unittest.expect(o.systemName, unittest.equals('foo'));
   }
   buildCounterMapTask--;
 }
 
 core.int buildCounterMetricShortId = 0;
 buildMetricShortId() {
   var o = new api.MetricShortId();
   buildCounterMetricShortId++;
   if (buildCounterMetricShortId < 3) {
     o.metricIndex = 42;
     o.shortId = "foo";
   }
   buildCounterMetricShortId--;
   return o;
 }
 
 checkMetricShortId(api.MetricShortId o) {
   buildCounterMetricShortId++;
   if (buildCounterMetricShortId < 3) {
     unittest.expect(o.metricIndex, unittest.equals(42));
     unittest.expect(o.shortId, unittest.equals('foo'));
   }
   buildCounterMetricShortId--;
 }
 
-buildUnnamed3118() {
+buildUnnamed3123() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3118(core.Map<core.String, core.String> o) {
+checkUnnamed3123(core.Map<core.String, core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o["x"], unittest.equals('foo'));
   unittest.expect(o["y"], unittest.equals('foo'));
 }
 
 core.int buildCounterMetricStructuredName = 0;
 buildMetricStructuredName() {
   var o = new api.MetricStructuredName();
   buildCounterMetricStructuredName++;
   if (buildCounterMetricStructuredName < 3) {
-    o.context = buildUnnamed3118();
+    o.context = buildUnnamed3123();
     o.name = "foo";
     o.origin = "foo";
   }
   buildCounterMetricStructuredName--;
   return o;
 }
 
 checkMetricStructuredName(api.MetricStructuredName o) {
   buildCounterMetricStructuredName++;
   if (buildCounterMetricStructuredName < 3) {
-    checkUnnamed3118(o.context);
+    checkUnnamed3123(o.context);
     unittest.expect(o.name, unittest.equals('foo'));
     unittest.expect(o.origin, unittest.equals('foo'));
   }
   buildCounterMetricStructuredName--;
 }
 
 core.int buildCounterMetricUpdate = 0;
 buildMetricUpdate() {
   var o = new api.MetricUpdate();
   buildCounterMetricUpdate++;
@@ skipping 101 matching lines @@
 
 checkPackage(api.Package o) {
   buildCounterPackage++;
   if (buildCounterPackage < 3) {
     unittest.expect(o.location, unittest.equals('foo'));
     unittest.expect(o.name, unittest.equals('foo'));
   }
   buildCounterPackage--;
 }
 
-buildUnnamed3119() {
+buildUnnamed3124() {
   var o = new core.List<api.MultiOutputInfo>();
   o.add(buildMultiOutputInfo());
   o.add(buildMultiOutputInfo());
   return o;
 }
 
-checkUnnamed3119(core.List<api.MultiOutputInfo> o) {
+checkUnnamed3124(core.List<api.MultiOutputInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkMultiOutputInfo(o[0]);
   checkMultiOutputInfo(o[1]);
 }
 
-buildUnnamed3120() {
+buildUnnamed3125() {
   var o = new core.List<api.SideInputInfo>();
   o.add(buildSideInputInfo());
   o.add(buildSideInputInfo());
   return o;
 }
 
-checkUnnamed3120(core.List<api.SideInputInfo> o) {
+checkUnnamed3125(core.List<api.SideInputInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSideInputInfo(o[0]);
   checkSideInputInfo(o[1]);
 }
 
-buildUnnamed3121() {
+buildUnnamed3126() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3121(core.Map<core.String, core.Object> o) {
+checkUnnamed3126(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
   var casted17 = (o["x"]) as core.Map; unittest.expect(casted17, unittest.hasLength(3)); unittest.expect(casted17["list"], unittest.equals([1, 2, 3])); unittest.expect(casted17["bool"], unittest.equals(true)); unittest.expect(casted17["string"], unittest.equals('foo')); 
   var casted18 = (o["y"]) as core.Map; unittest.expect(casted18, unittest.hasLength(3)); unittest.expect(casted18["list"], unittest.equals([1, 2, 3])); unittest.expect(casted18["bool"], unittest.equals(true)); unittest.expect(casted18["string"], unittest.equals('foo')); 
 }
 
 core.int buildCounterParDoInstruction = 0;
 buildParDoInstruction() {
   var o = new api.ParDoInstruction();
   buildCounterParDoInstruction++;
   if (buildCounterParDoInstruction < 3) {
     o.input = buildInstructionInput();
-    o.multiOutputInfos = buildUnnamed3119();
+    o.multiOutputInfos = buildUnnamed3124();
     o.numOutputs = 42;
-    o.sideInputs = buildUnnamed3120();
-    o.userFn = buildUnnamed3121();
+    o.sideInputs = buildUnnamed3125();
+    o.userFn = buildUnnamed3126();
   }
   buildCounterParDoInstruction--;
   return o;
 }
 
 checkParDoInstruction(api.ParDoInstruction o) {
   buildCounterParDoInstruction++;
   if (buildCounterParDoInstruction < 3) {
     checkInstructionInput(o.input);
-    checkUnnamed3119(o.multiOutputInfos);
+    checkUnnamed3124(o.multiOutputInfos);
     unittest.expect(o.numOutputs, unittest.equals(42));
-    checkUnnamed3120(o.sideInputs);
-    checkUnnamed3121(o.userFn);
+    checkUnnamed3125(o.sideInputs);
+    checkUnnamed3126(o.userFn);
   }
   buildCounterParDoInstruction--;
 }
 
-buildUnnamed3122() {
+buildUnnamed3127() {
   var o = new core.List<api.InstructionOutput>();
   o.add(buildInstructionOutput());
   o.add(buildInstructionOutput());
   return o;
 }
 
-checkUnnamed3122(core.List<api.InstructionOutput> o) {
+checkUnnamed3127(core.List<api.InstructionOutput> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkInstructionOutput(o[0]);
   checkInstructionOutput(o[1]);
 }
 
 core.int buildCounterParallelInstruction = 0;
 buildParallelInstruction() {
   var o = new api.ParallelInstruction();
   buildCounterParallelInstruction++;
   if (buildCounterParallelInstruction < 3) {
     o.flatten = buildFlattenInstruction();
     o.name = "foo";
     o.originalName = "foo";
-    o.outputs = buildUnnamed3122();
+    o.outputs = buildUnnamed3127();
     o.parDo = buildParDoInstruction();
     o.partialGroupByKey = buildPartialGroupByKeyInstruction();
     o.read = buildReadInstruction();
     o.systemName = "foo";
     o.write = buildWriteInstruction();
   }
   buildCounterParallelInstruction--;
   return o;
 }
 
 checkParallelInstruction(api.ParallelInstruction o) {
   buildCounterParallelInstruction++;
   if (buildCounterParallelInstruction < 3) {
     checkFlattenInstruction(o.flatten);
     unittest.expect(o.name, unittest.equals('foo'));
     unittest.expect(o.originalName, unittest.equals('foo'));
-    checkUnnamed3122(o.outputs);
+    checkUnnamed3127(o.outputs);
     checkParDoInstruction(o.parDo);
     checkPartialGroupByKeyInstruction(o.partialGroupByKey);
     checkReadInstruction(o.read);
     unittest.expect(o.systemName, unittest.equals('foo'));
     checkWriteInstruction(o.write);
   }
   buildCounterParallelInstruction--;
 }
 
-buildUnnamed3123() {
+core.int buildCounterParameter = 0;
+buildParameter() {
+  var o = new api.Parameter();
+  buildCounterParameter++;
+  if (buildCounterParameter < 3) {
+    o.key = "foo";
+    o.value = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
+  }
+  buildCounterParameter--;
+  return o;
+}
+
+checkParameter(api.Parameter o) {
+  buildCounterParameter++;
+  if (buildCounterParameter < 3) {
+    unittest.expect(o.key, unittest.equals('foo'));
+    var casted19 = (o.value) as core.Map; unittest.expect(casted19, unittest.hasLength(3)); unittest.expect(casted19["list"], unittest.equals([1, 2, 3])); unittest.expect(casted19["bool"], unittest.equals(true)); unittest.expect(casted19["string"], unittest.equals('foo')); 
+  }
+  buildCounterParameter--;
+}
+
+buildUnnamed3128() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3123(core.List<core.String> o) {
+checkUnnamed3128(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
 core.int buildCounterParameterMetadata = 0;
 buildParameterMetadata() {
   var o = new api.ParameterMetadata();
   buildCounterParameterMetadata++;
   if (buildCounterParameterMetadata < 3) {
     o.helpText = "foo";
     o.isOptional = true;
     o.label = "foo";
     o.name = "foo";
-    o.regexes = buildUnnamed3123();
+    o.regexes = buildUnnamed3128();
   }
   buildCounterParameterMetadata--;
   return o;
 }
 
 checkParameterMetadata(api.ParameterMetadata o) {
   buildCounterParameterMetadata++;
   if (buildCounterParameterMetadata < 3) {
     unittest.expect(o.helpText, unittest.equals('foo'));
     unittest.expect(o.isOptional, unittest.isTrue);
     unittest.expect(o.label, unittest.equals('foo'));
     unittest.expect(o.name, unittest.equals('foo'));
-    checkUnnamed3123(o.regexes);
+    checkUnnamed3128(o.regexes);
   }
   buildCounterParameterMetadata--;
 }
 
-buildUnnamed3124() {
+buildUnnamed3129() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3124(core.Map<core.String, core.Object> o) {
+checkUnnamed3129(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted19 = (o["x"]) as core.Map; unittest.expect(casted19, unittest.hasLength(3)); unittest.expect(casted19["list"], unittest.equals([1, 2, 3])); unittest.expect(casted19["bool"], unittest.equals(true)); unittest.expect(casted19["string"], unittest.equals('foo')); 
-  var casted20 = (o["y"]) as core.Map; unittest.expect(casted20, unittest.hasLength(3)); unittest.expect(casted20["list"], unittest.equals([1, 2, 3])); unittest.expect(casted20["bool"], unittest.equals(true)); unittest.expect(casted20["string"], unittest.equals('foo')); 
+  var casted20 = (o["x"]) as core.Map; unittest.expect(casted20, unittest.hasLength(3)); unittest.expect(casted20["list"], unittest.equals([1, 2, 3])); unittest.expect(casted20["bool"], unittest.equals(true)); unittest.expect(casted20["string"], unittest.equals('foo')); 
+  var casted21 = (o["y"]) as core.Map; unittest.expect(casted21, unittest.hasLength(3)); unittest.expect(casted21["list"], unittest.equals([1, 2, 3])); unittest.expect(casted21["bool"], unittest.equals(true)); unittest.expect(casted21["string"], unittest.equals('foo')); 
 }
 
-buildUnnamed3125() {
+buildUnnamed3130() {
   var o = new core.List<api.SideInputInfo>();
   o.add(buildSideInputInfo());
   o.add(buildSideInputInfo());
   return o;
 }
 
-checkUnnamed3125(core.List<api.SideInputInfo> o) {
+checkUnnamed3130(core.List<api.SideInputInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSideInputInfo(o[0]);
   checkSideInputInfo(o[1]);
 }
 
-buildUnnamed3126() {
+buildUnnamed3131() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3126(core.Map<core.String, core.Object> o) {
+checkUnnamed3131(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted21 = (o["x"]) as core.Map; unittest.expect(casted21, unittest.hasLength(3)); unittest.expect(casted21["list"], unittest.equals([1, 2, 3])); unittest.expect(casted21["bool"], unittest.equals(true)); unittest.expect(casted21["string"], unittest.equals('foo')); 
-  var casted22 = (o["y"]) as core.Map; unittest.expect(casted22, unittest.hasLength(3)); unittest.expect(casted22["list"], unittest.equals([1, 2, 3])); unittest.expect(casted22["bool"], unittest.equals(true)); unittest.expect(casted22["string"], unittest.equals('foo')); 
+  var casted22 = (o["x"]) as core.Map; unittest.expect(casted22, unittest.hasLength(3)); unittest.expect(casted22["list"], unittest.equals([1, 2, 3])); unittest.expect(casted22["bool"], unittest.equals(true)); unittest.expect(casted22["string"], unittest.equals('foo')); 
+  var casted23 = (o["y"]) as core.Map; unittest.expect(casted23, unittest.hasLength(3)); unittest.expect(casted23["list"], unittest.equals([1, 2, 3])); unittest.expect(casted23["bool"], unittest.equals(true)); unittest.expect(casted23["string"], unittest.equals('foo')); 
 }
 
 core.int buildCounterPartialGroupByKeyInstruction = 0;
 buildPartialGroupByKeyInstruction() {
   var o = new api.PartialGroupByKeyInstruction();
   buildCounterPartialGroupByKeyInstruction++;
   if (buildCounterPartialGroupByKeyInstruction < 3) {
     o.input = buildInstructionInput();
-    o.inputElementCodec = buildUnnamed3124();
+    o.inputElementCodec = buildUnnamed3129();
     o.originalCombineValuesInputStoreName = "foo";
     o.originalCombineValuesStepName = "foo";
-    o.sideInputs = buildUnnamed3125();
-    o.valueCombiningFn = buildUnnamed3126();
+    o.sideInputs = buildUnnamed3130();
+    o.valueCombiningFn = buildUnnamed3131();
   }
   buildCounterPartialGroupByKeyInstruction--;
   return o;
 }
 
 checkPartialGroupByKeyInstruction(api.PartialGroupByKeyInstruction o) {
   buildCounterPartialGroupByKeyInstruction++;
   if (buildCounterPartialGroupByKeyInstruction < 3) {
     checkInstructionInput(o.input);
-    checkUnnamed3124(o.inputElementCodec);
+    checkUnnamed3129(o.inputElementCodec);
     unittest.expect(o.originalCombineValuesInputStoreName, unittest.equals('foo'));
     unittest.expect(o.originalCombineValuesStepName, unittest.equals('foo'));
-    checkUnnamed3125(o.sideInputs);
-    checkUnnamed3126(o.valueCombiningFn);
+    checkUnnamed3130(o.sideInputs);
+    checkUnnamed3131(o.valueCombiningFn);
   }
   buildCounterPartialGroupByKeyInstruction--;
 }
 
-buildUnnamed3127() {
+buildUnnamed3132() {
   var o = new core.List<api.DisplayData>();
   o.add(buildDisplayData());
   o.add(buildDisplayData());
   return o;
 }
 
-checkUnnamed3127(core.List<api.DisplayData> o) {
+checkUnnamed3132(core.List<api.DisplayData> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkDisplayData(o[0]);
   checkDisplayData(o[1]);
 }
 
-buildUnnamed3128() {
+buildUnnamed3133() {
   var o = new core.List<api.ExecutionStageSummary>();
   o.add(buildExecutionStageSummary());
   o.add(buildExecutionStageSummary());
   return o;
 }
 
-checkUnnamed3128(core.List<api.ExecutionStageSummary> o) {
+checkUnnamed3133(core.List<api.ExecutionStageSummary> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkExecutionStageSummary(o[0]);
   checkExecutionStageSummary(o[1]);
 }
 
-buildUnnamed3129() {
+buildUnnamed3134() {
   var o = new core.List<api.TransformSummary>();
   o.add(buildTransformSummary());
   o.add(buildTransformSummary());
   return o;
 }
 
-checkUnnamed3129(core.List<api.TransformSummary> o) {
+checkUnnamed3134(core.List<api.TransformSummary> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkTransformSummary(o[0]);
   checkTransformSummary(o[1]);
 }
 
 core.int buildCounterPipelineDescription = 0;
 buildPipelineDescription() {
   var o = new api.PipelineDescription();
   buildCounterPipelineDescription++;
   if (buildCounterPipelineDescription < 3) {
-    o.displayData = buildUnnamed3127();
-    o.executionPipelineStage = buildUnnamed3128();
-    o.originalPipelineTransform = buildUnnamed3129();
+    o.displayData = buildUnnamed3132();
+    o.executionPipelineStage = buildUnnamed3133();
+    o.originalPipelineTransform = buildUnnamed3134();
   }
   buildCounterPipelineDescription--;
   return o;
 }
 
 checkPipelineDescription(api.PipelineDescription o) {
   buildCounterPipelineDescription++;
   if (buildCounterPipelineDescription < 3) {
-    checkUnnamed3127(o.displayData);
-    checkUnnamed3128(o.executionPipelineStage);
-    checkUnnamed3129(o.originalPipelineTransform);
+    checkUnnamed3132(o.displayData);
+    checkUnnamed3133(o.executionPipelineStage);
+    checkUnnamed3134(o.originalPipelineTransform);
   }
   buildCounterPipelineDescription--;
 }
 
 core.int buildCounterPosition = 0;
 buildPosition() {
   var o = new api.Position();
   buildCounterPosition++;
   if (buildCounterPosition < 3) {
     o.byteOffset = "foo";
@@ skipping 63 matching lines @@
 }
 
 checkReadInstruction(api.ReadInstruction o) {
   buildCounterReadInstruction++;
   if (buildCounterReadInstruction < 3) {
     checkSource(o.source);
   }
   buildCounterReadInstruction--;
 }
 
-buildUnnamed3130() {
+buildUnnamed3135() {
   var o = new core.List<api.WorkItemStatus>();
   o.add(buildWorkItemStatus());
   o.add(buildWorkItemStatus());
   return o;
 }
 
-checkUnnamed3130(core.List<api.WorkItemStatus> o) {
+checkUnnamed3135(core.List<api.WorkItemStatus> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkItemStatus(o[0]);
   checkWorkItemStatus(o[1]);
 }
 
 core.int buildCounterReportWorkItemStatusRequest = 0;
 buildReportWorkItemStatusRequest() {
   var o = new api.ReportWorkItemStatusRequest();
   buildCounterReportWorkItemStatusRequest++;
   if (buildCounterReportWorkItemStatusRequest < 3) {
     o.currentWorkerTime = "foo";
     o.location = "foo";
-    o.workItemStatuses = buildUnnamed3130();
+    o.workItemStatuses = buildUnnamed3135();
     o.workerId = "foo";
   }
   buildCounterReportWorkItemStatusRequest--;
   return o;
 }
 
 checkReportWorkItemStatusRequest(api.ReportWorkItemStatusRequest o) {
   buildCounterReportWorkItemStatusRequest++;
   if (buildCounterReportWorkItemStatusRequest < 3) {
     unittest.expect(o.currentWorkerTime, unittest.equals('foo'));
     unittest.expect(o.location, unittest.equals('foo'));
-    checkUnnamed3130(o.workItemStatuses);
+    checkUnnamed3135(o.workItemStatuses);
     unittest.expect(o.workerId, unittest.equals('foo'));
   }
   buildCounterReportWorkItemStatusRequest--;
 }
 
-buildUnnamed3131() {
+buildUnnamed3136() {
   var o = new core.List<api.WorkItemServiceState>();
   o.add(buildWorkItemServiceState());
   o.add(buildWorkItemServiceState());
   return o;
 }
 
-checkUnnamed3131(core.List<api.WorkItemServiceState> o) {
+checkUnnamed3136(core.List<api.WorkItemServiceState> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkItemServiceState(o[0]);
   checkWorkItemServiceState(o[1]);
 }
 
 core.int buildCounterReportWorkItemStatusResponse = 0;
 buildReportWorkItemStatusResponse() {
   var o = new api.ReportWorkItemStatusResponse();
   buildCounterReportWorkItemStatusResponse++;
   if (buildCounterReportWorkItemStatusResponse < 3) {
-    o.workItemServiceStates = buildUnnamed3131();
+    o.workItemServiceStates = buildUnnamed3136();
   }
   buildCounterReportWorkItemStatusResponse--;
   return o;
 }
 
 checkReportWorkItemStatusResponse(api.ReportWorkItemStatusResponse o) {
   buildCounterReportWorkItemStatusResponse++;
   if (buildCounterReportWorkItemStatusResponse < 3) {
-    checkUnnamed3131(o.workItemServiceStates);
+    checkUnnamed3136(o.workItemServiceStates);
   }
   buildCounterReportWorkItemStatusResponse--;
 }
 
 core.int buildCounterReportedParallelism = 0;
 buildReportedParallelism() {
   var o = new api.ReportedParallelism();
   buildCounterReportedParallelism++;
   if (buildCounterReportedParallelism < 3) {
     o.isInfinite = true;
     o.value = 42.0;
   }
   buildCounterReportedParallelism--;
   return o;
 }
 
 checkReportedParallelism(api.ReportedParallelism o) {
   buildCounterReportedParallelism++;
   if (buildCounterReportedParallelism < 3) {
     unittest.expect(o.isInfinite, unittest.isTrue);
     unittest.expect(o.value, unittest.equals(42.0));
   }
   buildCounterReportedParallelism--;
 }
 
-buildUnnamed3132() {
+buildUnnamed3137() {
   var o = new core.List<api.CPUTime>();
   o.add(buildCPUTime());
   o.add(buildCPUTime());
   return o;
 }
 
-checkUnnamed3132(core.List<api.CPUTime> o) {
+checkUnnamed3137(core.List<api.CPUTime> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkCPUTime(o[0]);
   checkCPUTime(o[1]);
 }
 
 core.int buildCounterResourceUtilizationReport = 0;
 buildResourceUtilizationReport() {
   var o = new api.ResourceUtilizationReport();
   buildCounterResourceUtilizationReport++;
   if (buildCounterResourceUtilizationReport < 3) {
-    o.cpuTime = buildUnnamed3132();
+    o.cpuTime = buildUnnamed3137();
   }
   buildCounterResourceUtilizationReport--;
   return o;
 }
 
 checkResourceUtilizationReport(api.ResourceUtilizationReport o) {
   buildCounterResourceUtilizationReport++;
   if (buildCounterResourceUtilizationReport < 3) {
-    checkUnnamed3132(o.cpuTime);
+    checkUnnamed3137(o.cpuTime);
   }
   buildCounterResourceUtilizationReport--;
 }
 
 core.int buildCounterResourceUtilizationReportResponse = 0;
 buildResourceUtilizationReportResponse() {
   var o = new api.ResourceUtilizationReportResponse();
   buildCounterResourceUtilizationReportResponse++;
   if (buildCounterResourceUtilizationReportResponse < 3) {
   }
@@ skipping 35 matching lines @@
   buildCounterRuntimeEnvironment--;
 }
 
 core.int buildCounterSendDebugCaptureRequest = 0;
 buildSendDebugCaptureRequest() {
   var o = new api.SendDebugCaptureRequest();
   buildCounterSendDebugCaptureRequest++;
   if (buildCounterSendDebugCaptureRequest < 3) {
     o.componentId = "foo";
     o.data = "foo";
+    o.location = "foo";
     o.workerId = "foo";
   }
   buildCounterSendDebugCaptureRequest--;
   return o;
 }
 
 checkSendDebugCaptureRequest(api.SendDebugCaptureRequest o) {
   buildCounterSendDebugCaptureRequest++;
   if (buildCounterSendDebugCaptureRequest < 3) {
     unittest.expect(o.componentId, unittest.equals('foo'));
     unittest.expect(o.data, unittest.equals('foo'));
+    unittest.expect(o.location, unittest.equals('foo'));
     unittest.expect(o.workerId, unittest.equals('foo'));
   }
   buildCounterSendDebugCaptureRequest--;
 }
 
 core.int buildCounterSendDebugCaptureResponse = 0;
 buildSendDebugCaptureResponse() {
   var o = new api.SendDebugCaptureResponse();
   buildCounterSendDebugCaptureResponse++;
   if (buildCounterSendDebugCaptureResponse < 3) {
   }
   buildCounterSendDebugCaptureResponse--;
   return o;
 }
 
 checkSendDebugCaptureResponse(api.SendDebugCaptureResponse o) {
   buildCounterSendDebugCaptureResponse++;
   if (buildCounterSendDebugCaptureResponse < 3) {
   }
   buildCounterSendDebugCaptureResponse--;
 }
 
-buildUnnamed3133() {
+buildUnnamed3138() {
   var o = new core.List<api.WorkerMessage>();
   o.add(buildWorkerMessage());
   o.add(buildWorkerMessage());
   return o;
 }
 
-checkUnnamed3133(core.List<api.WorkerMessage> o) {
+checkUnnamed3138(core.List<api.WorkerMessage> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkerMessage(o[0]);
   checkWorkerMessage(o[1]);
 }
 
 core.int buildCounterSendWorkerMessagesRequest = 0;
 buildSendWorkerMessagesRequest() {
   var o = new api.SendWorkerMessagesRequest();
   buildCounterSendWorkerMessagesRequest++;
   if (buildCounterSendWorkerMessagesRequest < 3) {
-    o.workerMessages = buildUnnamed3133();
+    o.location = "foo";
+    o.workerMessages = buildUnnamed3138();
   }
   buildCounterSendWorkerMessagesRequest--;
   return o;
 }
 
 checkSendWorkerMessagesRequest(api.SendWorkerMessagesRequest o) {
   buildCounterSendWorkerMessagesRequest++;
   if (buildCounterSendWorkerMessagesRequest < 3) {
-    checkUnnamed3133(o.workerMessages);
+    unittest.expect(o.location, unittest.equals('foo'));
+    checkUnnamed3138(o.workerMessages);
   }
   buildCounterSendWorkerMessagesRequest--;
 }
 
-buildUnnamed3134() {
+buildUnnamed3139() {
   var o = new core.List<api.WorkerMessageResponse>();
   o.add(buildWorkerMessageResponse());
   o.add(buildWorkerMessageResponse());
   return o;
 }
 
-checkUnnamed3134(core.List<api.WorkerMessageResponse> o) {
+checkUnnamed3139(core.List<api.WorkerMessageResponse> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkerMessageResponse(o[0]);
   checkWorkerMessageResponse(o[1]);
 }
 
 core.int buildCounterSendWorkerMessagesResponse = 0;
 buildSendWorkerMessagesResponse() {
   var o = new api.SendWorkerMessagesResponse();
   buildCounterSendWorkerMessagesResponse++;
   if (buildCounterSendWorkerMessagesResponse < 3) {
-    o.workerMessageResponses = buildUnnamed3134();
+    o.workerMessageResponses = buildUnnamed3139();
   }
   buildCounterSendWorkerMessagesResponse--;
   return o;
 }
 
 checkSendWorkerMessagesResponse(api.SendWorkerMessagesResponse o) {
   buildCounterSendWorkerMessagesResponse++;
   if (buildCounterSendWorkerMessagesResponse < 3) {
-    checkUnnamed3134(o.workerMessageResponses);
+    checkUnnamed3139(o.workerMessageResponses);
   }
   buildCounterSendWorkerMessagesResponse--;
 }
 
-buildUnnamed3135() {
+buildUnnamed3140() {
   var o = new core.List<api.SideInputInfo>();
   o.add(buildSideInputInfo());
   o.add(buildSideInputInfo());
   return o;
 }
 
-checkUnnamed3135(core.List<api.SideInputInfo> o) {
+checkUnnamed3140(core.List<api.SideInputInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSideInputInfo(o[0]);
   checkSideInputInfo(o[1]);
 }
 
-buildUnnamed3136() {
+buildUnnamed3141() {
   var o = new core.List<api.SeqMapTaskOutputInfo>();
   o.add(buildSeqMapTaskOutputInfo());
   o.add(buildSeqMapTaskOutputInfo());
   return o;
 }
 
-checkUnnamed3136(core.List<api.SeqMapTaskOutputInfo> o) {
+checkUnnamed3141(core.List<api.SeqMapTaskOutputInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSeqMapTaskOutputInfo(o[0]);
   checkSeqMapTaskOutputInfo(o[1]);
 }
 
-buildUnnamed3137() {
+buildUnnamed3142() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3137(core.Map<core.String, core.Object> o) {
+checkUnnamed3142(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted23 = (o["x"]) as core.Map; unittest.expect(casted23, unittest.hasLength(3)); unittest.expect(casted23["list"], unittest.equals([1, 2, 3])); unittest.expect(casted23["bool"], unittest.equals(true)); unittest.expect(casted23["string"], unittest.equals('foo')); 
-  var casted24 = (o["y"]) as core.Map; unittest.expect(casted24, unittest.hasLength(3)); unittest.expect(casted24["list"], unittest.equals([1, 2, 3])); unittest.expect(casted24["bool"], unittest.equals(true)); unittest.expect(casted24["string"], unittest.equals('foo')); 
+  var casted24 = (o["x"]) as core.Map; unittest.expect(casted24, unittest.hasLength(3)); unittest.expect(casted24["list"], unittest.equals([1, 2, 3])); unittest.expect(casted24["bool"], unittest.equals(true)); unittest.expect(casted24["string"], unittest.equals('foo')); 
+  var casted25 = (o["y"]) as core.Map; unittest.expect(casted25, unittest.hasLength(3)); unittest.expect(casted25["list"], unittest.equals([1, 2, 3])); unittest.expect(casted25["bool"], unittest.equals(true)); unittest.expect(casted25["string"], unittest.equals('foo')); 
 }
 
 core.int buildCounterSeqMapTask = 0;
 buildSeqMapTask() {
   var o = new api.SeqMapTask();
   buildCounterSeqMapTask++;
   if (buildCounterSeqMapTask < 3) {
-    o.inputs = buildUnnamed3135();
+    o.inputs = buildUnnamed3140();
     o.name = "foo";
-    o.outputInfos = buildUnnamed3136();
+    o.outputInfos = buildUnnamed3141();
     o.stageName = "foo";
     o.systemName = "foo";
-    o.userFn = buildUnnamed3137();
+    o.userFn = buildUnnamed3142();
   }
   buildCounterSeqMapTask--;
   return o;
 }
 
 checkSeqMapTask(api.SeqMapTask o) {
   buildCounterSeqMapTask++;
   if (buildCounterSeqMapTask < 3) {
-    checkUnnamed3135(o.inputs);
+    checkUnnamed3140(o.inputs);
     unittest.expect(o.name, unittest.equals('foo'));
-    checkUnnamed3136(o.outputInfos);
+    checkUnnamed3141(o.outputInfos);
     unittest.expect(o.stageName, unittest.equals('foo'));
     unittest.expect(o.systemName, unittest.equals('foo'));
-    checkUnnamed3137(o.userFn);
+    checkUnnamed3142(o.userFn);
   }
   buildCounterSeqMapTask--;
 }
 
 core.int buildCounterSeqMapTaskOutputInfo = 0;
 buildSeqMapTaskOutputInfo() {
   var o = new api.SeqMapTaskOutputInfo();
   buildCounterSeqMapTaskOutputInfo++;
   if (buildCounterSeqMapTaskOutputInfo < 3) {
     o.sink = buildSink();
@@ skipping 26 matching lines @@
 
 checkShellTask(api.ShellTask o) {
   buildCounterShellTask++;
   if (buildCounterShellTask < 3) {
     unittest.expect(o.command, unittest.equals('foo'));
     unittest.expect(o.exitCode, unittest.equals(42));
   }
   buildCounterShellTask--;
 }
 
-buildUnnamed3138() {
+buildUnnamed3143() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3138(core.Map<core.String, core.Object> o) {
+checkUnnamed3143(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted25 = (o["x"]) as core.Map; unittest.expect(casted25, unittest.hasLength(3)); unittest.expect(casted25["list"], unittest.equals([1, 2, 3])); unittest.expect(casted25["bool"], unittest.equals(true)); unittest.expect(casted25["string"], unittest.equals('foo')); 
-  var casted26 = (o["y"]) as core.Map; unittest.expect(casted26, unittest.hasLength(3)); unittest.expect(casted26["list"], unittest.equals([1, 2, 3])); unittest.expect(casted26["bool"], unittest.equals(true)); unittest.expect(casted26["string"], unittest.equals('foo')); 
+  var casted26 = (o["x"]) as core.Map; unittest.expect(casted26, unittest.hasLength(3)); unittest.expect(casted26["list"], unittest.equals([1, 2, 3])); unittest.expect(casted26["bool"], unittest.equals(true)); unittest.expect(casted26["string"], unittest.equals('foo')); 
+  var casted27 = (o["y"]) as core.Map; unittest.expect(casted27, unittest.hasLength(3)); unittest.expect(casted27["list"], unittest.equals([1, 2, 3])); unittest.expect(casted27["bool"], unittest.equals(true)); unittest.expect(casted27["string"], unittest.equals('foo')); 
 }
 
-buildUnnamed3139() {
+buildUnnamed3144() {
   var o = new core.List<api.Source>();
   o.add(buildSource());
   o.add(buildSource());
   return o;
 }
 
-checkUnnamed3139(core.List<api.Source> o) {
+checkUnnamed3144(core.List<api.Source> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSource(o[0]);
   checkSource(o[1]);
 }
 
 core.int buildCounterSideInputInfo = 0;
 buildSideInputInfo() {
   var o = new api.SideInputInfo();
   buildCounterSideInputInfo++;
   if (buildCounterSideInputInfo < 3) {
-    o.kind = buildUnnamed3138();
-    o.sources = buildUnnamed3139();
+    o.kind = buildUnnamed3143();
+    o.sources = buildUnnamed3144();
     o.tag = "foo";
   }
   buildCounterSideInputInfo--;
   return o;
 }
 
 checkSideInputInfo(api.SideInputInfo o) {
   buildCounterSideInputInfo++;
   if (buildCounterSideInputInfo < 3) {
-    checkUnnamed3138(o.kind);
-    checkUnnamed3139(o.sources);
+    checkUnnamed3143(o.kind);
+    checkUnnamed3144(o.sources);
     unittest.expect(o.tag, unittest.equals('foo'));
   }
   buildCounterSideInputInfo--;
 }
 
-buildUnnamed3140() {
+buildUnnamed3145() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3140(core.Map<core.String, core.Object> o) {
+checkUnnamed3145(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted27 = (o["x"]) as core.Map; unittest.expect(casted27, unittest.hasLength(3)); unittest.expect(casted27["list"], unittest.equals([1, 2, 3])); unittest.expect(casted27["bool"], unittest.equals(true)); unittest.expect(casted27["string"], unittest.equals('foo')); 
-  var casted28 = (o["y"]) as core.Map; unittest.expect(casted28, unittest.hasLength(3)); unittest.expect(casted28["list"], unittest.equals([1, 2, 3])); unittest.expect(casted28["bool"], unittest.equals(true)); unittest.expect(casted28["string"], unittest.equals('foo')); 
+  var casted28 = (o["x"]) as core.Map; unittest.expect(casted28, unittest.hasLength(3)); unittest.expect(casted28["list"], unittest.equals([1, 2, 3])); unittest.expect(casted28["bool"], unittest.equals(true)); unittest.expect(casted28["string"], unittest.equals('foo')); 
+  var casted29 = (o["y"]) as core.Map; unittest.expect(casted29, unittest.hasLength(3)); unittest.expect(casted29["list"], unittest.equals([1, 2, 3])); unittest.expect(casted29["bool"], unittest.equals(true)); unittest.expect(casted29["string"], unittest.equals('foo')); 
 }
 
-buildUnnamed3141() {
+buildUnnamed3146() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3141(core.Map<core.String, core.Object> o) {
+checkUnnamed3146(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted29 = (o["x"]) as core.Map; unittest.expect(casted29, unittest.hasLength(3)); unittest.expect(casted29["list"], unittest.equals([1, 2, 3])); unittest.expect(casted29["bool"], unittest.equals(true)); unittest.expect(casted29["string"], unittest.equals('foo')); 
-  var casted30 = (o["y"]) as core.Map; unittest.expect(casted30, unittest.hasLength(3)); unittest.expect(casted30["list"], unittest.equals([1, 2, 3])); unittest.expect(casted30["bool"], unittest.equals(true)); unittest.expect(casted30["string"], unittest.equals('foo')); 
+  var casted30 = (o["x"]) as core.Map; unittest.expect(casted30, unittest.hasLength(3)); unittest.expect(casted30["list"], unittest.equals([1, 2, 3])); unittest.expect(casted30["bool"], unittest.equals(true)); unittest.expect(casted30["string"], unittest.equals('foo')); 
+  var casted31 = (o["y"]) as core.Map; unittest.expect(casted31, unittest.hasLength(3)); unittest.expect(casted31["list"], unittest.equals([1, 2, 3])); unittest.expect(casted31["bool"], unittest.equals(true)); unittest.expect(casted31["string"], unittest.equals('foo')); 
 }
 
 core.int buildCounterSink = 0;
 buildSink() {
   var o = new api.Sink();
   buildCounterSink++;
   if (buildCounterSink < 3) {
-    o.codec = buildUnnamed3140();
-    o.spec = buildUnnamed3141();
+    o.codec = buildUnnamed3145();
+    o.spec = buildUnnamed3146();
   }
   buildCounterSink--;
   return o;
 }
 
 checkSink(api.Sink o) {
   buildCounterSink++;
   if (buildCounterSink < 3) {
-    checkUnnamed3140(o.codec);
-    checkUnnamed3141(o.spec);
+    checkUnnamed3145(o.codec);
+    checkUnnamed3146(o.spec);
   }
   buildCounterSink--;
 }
 
-buildUnnamed3142() {
+buildUnnamed3147() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3142(core.Map<core.String, core.Object> o) {
+checkUnnamed3147(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted31 = (o["x"]) as core.Map; unittest.expect(casted31, unittest.hasLength(3)); unittest.expect(casted31["list"], unittest.equals([1, 2, 3])); unittest.expect(casted31["bool"], unittest.equals(true)); unittest.expect(casted31["string"], unittest.equals('foo')); 
-  var casted32 = (o["y"]) as core.Map; unittest.expect(casted32, unittest.hasLength(3)); unittest.expect(casted32["list"], unittest.equals([1, 2, 3])); unittest.expect(casted32["bool"], unittest.equals(true)); unittest.expect(casted32["string"], unittest.equals('foo')); 
+  var casted32 = (o["x"]) as core.Map; unittest.expect(casted32, unittest.hasLength(3)); unittest.expect(casted32["list"], unittest.equals([1, 2, 3])); unittest.expect(casted32["bool"], unittest.equals(true)); unittest.expect(casted32["string"], unittest.equals('foo')); 
+  var casted33 = (o["y"]) as core.Map; unittest.expect(casted33, unittest.hasLength(3)); unittest.expect(casted33["list"], unittest.equals([1, 2, 3])); unittest.expect(casted33["bool"], unittest.equals(true)); unittest.expect(casted33["string"], unittest.equals('foo')); 
 }
 
-buildUnnamed3143() {
+buildUnnamed3148() {
   var o = new core.List<core.Map<core.String, core.Object>>();
-  o.add(buildUnnamed3142());
-  o.add(buildUnnamed3142());
+  o.add(buildUnnamed3147());
+  o.add(buildUnnamed3147());
   return o;
 }
 
-checkUnnamed3143(core.List<core.Map<core.String, core.Object>> o) {
+checkUnnamed3148(core.List<core.Map<core.String, core.Object>> o) {
   unittest.expect(o, unittest.hasLength(2));
-  checkUnnamed3142(o[0]);
-  checkUnnamed3142(o[1]);
+  checkUnnamed3147(o[0]);
+  checkUnnamed3147(o[1]);
 }
 
-buildUnnamed3144() {
+buildUnnamed3149() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3144(core.Map<core.String, core.Object> o) {
+checkUnnamed3149(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted33 = (o["x"]) as core.Map; unittest.expect(casted33, unittest.hasLength(3)); unittest.expect(casted33["list"], unittest.equals([1, 2, 3])); unittest.expect(casted33["bool"], unittest.equals(true)); unittest.expect(casted33["string"], unittest.equals('foo')); 
-  var casted34 = (o["y"]) as core.Map; unittest.expect(casted34, unittest.hasLength(3)); unittest.expect(casted34["list"], unittest.equals([1, 2, 3])); unittest.expect(casted34["bool"], unittest.equals(true)); unittest.expect(casted34["string"], unittest.equals('foo')); 
+  var casted34 = (o["x"]) as core.Map; unittest.expect(casted34, unittest.hasLength(3)); unittest.expect(casted34["list"], unittest.equals([1, 2, 3])); unittest.expect(casted34["bool"], unittest.equals(true)); unittest.expect(casted34["string"], unittest.equals('foo')); 
+  var casted35 = (o["y"]) as core.Map; unittest.expect(casted35, unittest.hasLength(3)); unittest.expect(casted35["list"], unittest.equals([1, 2, 3])); unittest.expect(casted35["bool"], unittest.equals(true)); unittest.expect(casted35["string"], unittest.equals('foo')); 
 }
 
-buildUnnamed3145() {
+buildUnnamed3150() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3145(core.Map<core.String, core.Object> o) {
+checkUnnamed3150(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted35 = (o["x"]) as core.Map; unittest.expect(casted35, unittest.hasLength(3)); unittest.expect(casted35["list"], unittest.equals([1, 2, 3])); unittest.expect(casted35["bool"], unittest.equals(true)); unittest.expect(casted35["string"], unittest.equals('foo')); 
-  var casted36 = (o["y"]) as core.Map; unittest.expect(casted36, unittest.hasLength(3)); unittest.expect(casted36["list"], unittest.equals([1, 2, 3])); unittest.expect(casted36["bool"], unittest.equals(true)); unittest.expect(casted36["string"], unittest.equals('foo')); 
+  var casted36 = (o["x"]) as core.Map; unittest.expect(casted36, unittest.hasLength(3)); unittest.expect(casted36["list"], unittest.equals([1, 2, 3])); unittest.expect(casted36["bool"], unittest.equals(true)); unittest.expect(casted36["string"], unittest.equals('foo')); 
+  var casted37 = (o["y"]) as core.Map; unittest.expect(casted37, unittest.hasLength(3)); unittest.expect(casted37["list"], unittest.equals([1, 2, 3])); unittest.expect(casted37["bool"], unittest.equals(true)); unittest.expect(casted37["string"], unittest.equals('foo')); 
 }
 
 core.int buildCounterSource = 0;
 buildSource() {
   var o = new api.Source();
   buildCounterSource++;
   if (buildCounterSource < 3) {
-    o.baseSpecs = buildUnnamed3143();
-    o.codec = buildUnnamed3144();
+    o.baseSpecs = buildUnnamed3148();
+    o.codec = buildUnnamed3149();
     o.doesNotNeedSplitting = true;
     o.metadata = buildSourceMetadata();
-    o.spec = buildUnnamed3145();
+    o.spec = buildUnnamed3150();
   }
   buildCounterSource--;
   return o;
 }
 
 checkSource(api.Source o) {
   buildCounterSource++;
   if (buildCounterSource < 3) {
-    checkUnnamed3143(o.baseSpecs);
-    checkUnnamed3144(o.codec);
+    checkUnnamed3148(o.baseSpecs);
+    checkUnnamed3149(o.codec);
     unittest.expect(o.doesNotNeedSplitting, unittest.isTrue);
     checkSourceMetadata(o.metadata);
-    checkUnnamed3145(o.spec);
+    checkUnnamed3150(o.spec);
   }
   buildCounterSource--;
 }
 
 core.int buildCounterSourceFork = 0;
 buildSourceFork() {
   var o = new api.SourceFork();
   buildCounterSourceFork++;
   if (buildCounterSourceFork < 3) {
     o.primary = buildSourceSplitShard();
@@ skipping 154 matching lines @@
 
 checkSourceSplitRequest(api.SourceSplitRequest o) {
   buildCounterSourceSplitRequest++;
   if (buildCounterSourceSplitRequest < 3) {
     checkSourceSplitOptions(o.options);
     checkSource(o.source);
   }
   buildCounterSourceSplitRequest--;
 }
 
-buildUnnamed3146() {
+buildUnnamed3151() {
   var o = new core.List<api.DerivedSource>();
   o.add(buildDerivedSource());
   o.add(buildDerivedSource());
   return o;
 }
 
-checkUnnamed3146(core.List<api.DerivedSource> o) {
+checkUnnamed3151(core.List<api.DerivedSource> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkDerivedSource(o[0]);
   checkDerivedSource(o[1]);
 }
 
-buildUnnamed3147() {
+buildUnnamed3152() {
   var o = new core.List<api.SourceSplitShard>();
   o.add(buildSourceSplitShard());
   o.add(buildSourceSplitShard());
   return o;
 }
 
-checkUnnamed3147(core.List<api.SourceSplitShard> o) {
+checkUnnamed3152(core.List<api.SourceSplitShard> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSourceSplitShard(o[0]);
   checkSourceSplitShard(o[1]);
 }
 
 core.int buildCounterSourceSplitResponse = 0;
 buildSourceSplitResponse() {
   var o = new api.SourceSplitResponse();
   buildCounterSourceSplitResponse++;
   if (buildCounterSourceSplitResponse < 3) {
-    o.bundles = buildUnnamed3146();
+    o.bundles = buildUnnamed3151();
     o.outcome = "foo";
-    o.shards = buildUnnamed3147();
+    o.shards = buildUnnamed3152();
   }
   buildCounterSourceSplitResponse--;
   return o;
 }
 
 checkSourceSplitResponse(api.SourceSplitResponse o) {
   buildCounterSourceSplitResponse++;
   if (buildCounterSourceSplitResponse < 3) {
-    checkUnnamed3146(o.bundles);
+    checkUnnamed3151(o.bundles);
     unittest.expect(o.outcome, unittest.equals('foo'));
-    checkUnnamed3147(o.shards);
+    checkUnnamed3152(o.shards);
   }
   buildCounterSourceSplitResponse--;
 }
 
 core.int buildCounterSourceSplitShard = 0;
 buildSourceSplitShard() {
   var o = new api.SourceSplitShard();
   buildCounterSourceSplitShard++;
   if (buildCounterSourceSplitShard < 3) {
     o.derivationMode = "foo";
@@ skipping 72 matching lines @@
 
 checkStateFamilyConfig(api.StateFamilyConfig o) {
   buildCounterStateFamilyConfig++;
   if (buildCounterStateFamilyConfig < 3) {
     unittest.expect(o.isRead, unittest.isTrue);
     unittest.expect(o.stateFamily, unittest.equals('foo'));
   }
   buildCounterStateFamilyConfig--;
 }
 
-buildUnnamed3148() {
+buildUnnamed3153() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3148(core.Map<core.String, core.Object> o) {
+checkUnnamed3153(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted37 = (o["x"]) as core.Map; unittest.expect(casted37, unittest.hasLength(3)); unittest.expect(casted37["list"], unittest.equals([1, 2, 3])); unittest.expect(casted37["bool"], unittest.equals(true)); unittest.expect(casted37["string"], unittest.equals('foo')); 
-  var casted38 = (o["y"]) as core.Map; unittest.expect(casted38, unittest.hasLength(3)); unittest.expect(casted38["list"], unittest.equals([1, 2, 3])); unittest.expect(casted38["bool"], unittest.equals(true)); unittest.expect(casted38["string"], unittest.equals('foo')); 
+  var casted38 = (o["x"]) as core.Map; unittest.expect(casted38, unittest.hasLength(3)); unittest.expect(casted38["list"], unittest.equals([1, 2, 3])); unittest.expect(casted38["bool"], unittest.equals(true)); unittest.expect(casted38["string"], unittest.equals('foo')); 
+  var casted39 = (o["y"]) as core.Map; unittest.expect(casted39, unittest.hasLength(3)); unittest.expect(casted39["list"], unittest.equals([1, 2, 3])); unittest.expect(casted39["bool"], unittest.equals(true)); unittest.expect(casted39["string"], unittest.equals('foo')); 
 }
 
-buildUnnamed3149() {
+buildUnnamed3154() {
   var o = new core.List<core.Map<core.String, core.Object>>();
-  o.add(buildUnnamed3148());
-  o.add(buildUnnamed3148());
+  o.add(buildUnnamed3153());
+  o.add(buildUnnamed3153());
   return o;
 }
 
-checkUnnamed3149(core.List<core.Map<core.String, core.Object>> o) {
+checkUnnamed3154(core.List<core.Map<core.String, core.Object>> o) {
   unittest.expect(o, unittest.hasLength(2));
-  checkUnnamed3148(o[0]);
-  checkUnnamed3148(o[1]);
+  checkUnnamed3153(o[0]);
+  checkUnnamed3153(o[1]);
 }
 
 core.int buildCounterStatus = 0;
 buildStatus() {
   var o = new api.Status();
   buildCounterStatus++;
   if (buildCounterStatus < 3) {
     o.code = 42;
-    o.details = buildUnnamed3149();
+    o.details = buildUnnamed3154();
     o.message = "foo";
   }
   buildCounterStatus--;
   return o;
 }
 
 checkStatus(api.Status o) {
   buildCounterStatus++;
   if (buildCounterStatus < 3) {
     unittest.expect(o.code, unittest.equals(42));
-    checkUnnamed3149(o.details);
+    checkUnnamed3154(o.details);
     unittest.expect(o.message, unittest.equals('foo'));
   }
   buildCounterStatus--;
 }
 
-buildUnnamed3150() {
+buildUnnamed3155() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3150(core.Map<core.String, core.Object> o) {
+checkUnnamed3155(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted39 = (o["x"]) as core.Map; unittest.expect(casted39, unittest.hasLength(3)); unittest.expect(casted39["list"], unittest.equals([1, 2, 3])); unittest.expect(casted39["bool"], unittest.equals(true)); unittest.expect(casted39["string"], unittest.equals('foo')); 
-  var casted40 = (o["y"]) as core.Map; unittest.expect(casted40, unittest.hasLength(3)); unittest.expect(casted40["list"], unittest.equals([1, 2, 3])); unittest.expect(casted40["bool"], unittest.equals(true)); unittest.expect(casted40["string"], unittest.equals('foo')); 
+  var casted40 = (o["x"]) as core.Map; unittest.expect(casted40, unittest.hasLength(3)); unittest.expect(casted40["list"], unittest.equals([1, 2, 3])); unittest.expect(casted40["bool"], unittest.equals(true)); unittest.expect(casted40["string"], unittest.equals('foo')); 
+  var casted41 = (o["y"]) as core.Map; unittest.expect(casted41, unittest.hasLength(3)); unittest.expect(casted41["list"], unittest.equals([1, 2, 3])); unittest.expect(casted41["bool"], unittest.equals(true)); unittest.expect(casted41["string"], unittest.equals('foo')); 
 }
 
 core.int buildCounterStep = 0;
 buildStep() {
   var o = new api.Step();
   buildCounterStep++;
   if (buildCounterStep < 3) {
     o.kind = "foo";
     o.name = "foo";
-    o.properties = buildUnnamed3150();
+    o.properties = buildUnnamed3155();
   }
   buildCounterStep--;
   return o;
 }
 
 checkStep(api.Step o) {
   buildCounterStep++;
   if (buildCounterStep < 3) {
     unittest.expect(o.kind, unittest.equals('foo'));
     unittest.expect(o.name, unittest.equals('foo'));
-    checkUnnamed3150(o.properties);
+    checkUnnamed3155(o.properties);
   }
   buildCounterStep--;
 }
 
 core.int buildCounterStreamLocation = 0;
 buildStreamLocation() {
   var o = new api.StreamLocation();
   buildCounterStreamLocation++;
   if (buildCounterStreamLocation < 3) {
     o.customSourceLocation = buildCustomSourceLocation();
     o.pubsubLocation = buildPubsubLocation();
     o.sideInputLocation = buildStreamingSideInputLocation();
     o.streamingStageLocation = buildStreamingStageLocation();
   }
   buildCounterStreamLocation--;
   return o;
 }
 
 checkStreamLocation(api.StreamLocation o) {
   buildCounterStreamLocation++;
   if (buildCounterStreamLocation < 3) {
     checkCustomSourceLocation(o.customSourceLocation);
     checkPubsubLocation(o.pubsubLocation);
     checkStreamingSideInputLocation(o.sideInputLocation);
     checkStreamingStageLocation(o.streamingStageLocation);
   }
   buildCounterStreamLocation--;
 }
 
-buildUnnamed3151() {
+buildUnnamed3156() {
   var o = new core.List<api.ParallelInstruction>();
   o.add(buildParallelInstruction());
   o.add(buildParallelInstruction());
   return o;
 }
 
-checkUnnamed3151(core.List<api.ParallelInstruction> o) {
+checkUnnamed3156(core.List<api.ParallelInstruction> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkParallelInstruction(o[0]);
   checkParallelInstruction(o[1]);
 }
 
 core.int buildCounterStreamingComputationConfig = 0;
 buildStreamingComputationConfig() {
   var o = new api.StreamingComputationConfig();
   buildCounterStreamingComputationConfig++;
   if (buildCounterStreamingComputationConfig < 3) {
     o.computationId = "foo";
-    o.instructions = buildUnnamed3151();
+    o.instructions = buildUnnamed3156();
     o.stageName = "foo";
     o.systemName = "foo";
   }
   buildCounterStreamingComputationConfig--;
   return o;
 }
 
 checkStreamingComputationConfig(api.StreamingComputationConfig o) {
   buildCounterStreamingComputationConfig++;
   if (buildCounterStreamingComputationConfig < 3) {
     unittest.expect(o.computationId, unittest.equals('foo'));
-    checkUnnamed3151(o.instructions);
+    checkUnnamed3156(o.instructions);
     unittest.expect(o.stageName, unittest.equals('foo'));
     unittest.expect(o.systemName, unittest.equals('foo'));
   }
   buildCounterStreamingComputationConfig--;
 }
 
-buildUnnamed3152() {
+buildUnnamed3157() {
   var o = new core.List<api.KeyRangeDataDiskAssignment>();
   o.add(buildKeyRangeDataDiskAssignment());
   o.add(buildKeyRangeDataDiskAssignment());
   return o;
 }
 
-checkUnnamed3152(core.List<api.KeyRangeDataDiskAssignment> o) {
+checkUnnamed3157(core.List<api.KeyRangeDataDiskAssignment> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkKeyRangeDataDiskAssignment(o[0]);
   checkKeyRangeDataDiskAssignment(o[1]);
 }
 
 core.int buildCounterStreamingComputationRanges = 0;
 buildStreamingComputationRanges() {
   var o = new api.StreamingComputationRanges();
   buildCounterStreamingComputationRanges++;
   if (buildCounterStreamingComputationRanges < 3) {
     o.computationId = "foo";
-    o.rangeAssignments = buildUnnamed3152();
+    o.rangeAssignments = buildUnnamed3157();
   }
   buildCounterStreamingComputationRanges--;
   return o;
 }
 
 checkStreamingComputationRanges(api.StreamingComputationRanges o) {
   buildCounterStreamingComputationRanges++;
   if (buildCounterStreamingComputationRanges < 3) {
     unittest.expect(o.computationId, unittest.equals('foo'));
-    checkUnnamed3152(o.rangeAssignments);
+    checkUnnamed3157(o.rangeAssignments);
   }
   buildCounterStreamingComputationRanges--;
 }
 
-buildUnnamed3153() {
+buildUnnamed3158() {
   var o = new core.List<api.StreamingComputationRanges>();
   o.add(buildStreamingComputationRanges());
   o.add(buildStreamingComputationRanges());
   return o;
 }
 
-checkUnnamed3153(core.List<api.StreamingComputationRanges> o) {
+checkUnnamed3158(core.List<api.StreamingComputationRanges> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStreamingComputationRanges(o[0]);
   checkStreamingComputationRanges(o[1]);
 }
 
-buildUnnamed3154() {
+buildUnnamed3159() {
   var o = new core.List<api.MountedDataDisk>();
   o.add(buildMountedDataDisk());
   o.add(buildMountedDataDisk());
   return o;
 }
 
-checkUnnamed3154(core.List<api.MountedDataDisk> o) {
+checkUnnamed3159(core.List<api.MountedDataDisk> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkMountedDataDisk(o[0]);
   checkMountedDataDisk(o[1]);
 }
 
 core.int buildCounterStreamingComputationTask = 0;
 buildStreamingComputationTask() {
   var o = new api.StreamingComputationTask();
   buildCounterStreamingComputationTask++;
   if (buildCounterStreamingComputationTask < 3) {
-    o.computationRanges = buildUnnamed3153();
-    o.dataDisks = buildUnnamed3154();
+    o.computationRanges = buildUnnamed3158();
+    o.dataDisks = buildUnnamed3159();
     o.taskType = "foo";
   }
   buildCounterStreamingComputationTask--;
   return o;
 }
 
 checkStreamingComputationTask(api.StreamingComputationTask o) {
   buildCounterStreamingComputationTask++;
   if (buildCounterStreamingComputationTask < 3) {
-    checkUnnamed3153(o.computationRanges);
-    checkUnnamed3154(o.dataDisks);
+    checkUnnamed3158(o.computationRanges);
+    checkUnnamed3159(o.dataDisks);
     unittest.expect(o.taskType, unittest.equals('foo'));
   }
   buildCounterStreamingComputationTask--;
 }
 
-buildUnnamed3155() {
+buildUnnamed3160() {
   var o = new core.List<api.StreamingComputationConfig>();
   o.add(buildStreamingComputationConfig());
   o.add(buildStreamingComputationConfig());
   return o;
 }
 
-checkUnnamed3155(core.List<api.StreamingComputationConfig> o) {
+checkUnnamed3160(core.List<api.StreamingComputationConfig> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStreamingComputationConfig(o[0]);
   checkStreamingComputationConfig(o[1]);
 }
 
-buildUnnamed3156() {
+buildUnnamed3161() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3156(core.Map<core.String, core.String> o) {
+checkUnnamed3161(core.Map<core.String, core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o["x"], unittest.equals('foo'));
   unittest.expect(o["y"], unittest.equals('foo'));
 }
 
 core.int buildCounterStreamingConfigTask = 0;
 buildStreamingConfigTask() {
   var o = new api.StreamingConfigTask();
   buildCounterStreamingConfigTask++;
   if (buildCounterStreamingConfigTask < 3) {
-    o.streamingComputationConfigs = buildUnnamed3155();
-    o.userStepToStateFamilyNameMap = buildUnnamed3156();
+    o.streamingComputationConfigs = buildUnnamed3160();
+    o.userStepToStateFamilyNameMap = buildUnnamed3161();
   }
   buildCounterStreamingConfigTask--;
   return o;
 }
 
 checkStreamingConfigTask(api.StreamingConfigTask o) {
   buildCounterStreamingConfigTask++;
   if (buildCounterStreamingConfigTask < 3) {
-    checkUnnamed3155(o.streamingComputationConfigs);
-    checkUnnamed3156(o.userStepToStateFamilyNameMap);
+    checkUnnamed3160(o.streamingComputationConfigs);
+    checkUnnamed3161(o.userStepToStateFamilyNameMap);
   }
   buildCounterStreamingConfigTask--;
 }
 
 core.int buildCounterStreamingSetupTask = 0;
 buildStreamingSetupTask() {
   var o = new api.StreamingSetupTask();
   buildCounterStreamingSetupTask++;
   if (buildCounterStreamingSetupTask < 3) {
     o.drain = true;
@@ skipping 49 matching lines @@
 }
 
 checkStreamingStageLocation(api.StreamingStageLocation o) {
   buildCounterStreamingStageLocation++;
   if (buildCounterStreamingStageLocation < 3) {
     unittest.expect(o.streamId, unittest.equals('foo'));
   }
   buildCounterStreamingStageLocation--;
 }
 
-buildUnnamed3157() {
+buildUnnamed3162() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3157(core.List<core.String> o) {
+checkUnnamed3162(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
 core.int buildCounterStringList = 0;
 buildStringList() {
   var o = new api.StringList();
   buildCounterStringList++;
   if (buildCounterStringList < 3) {
-    o.elements = buildUnnamed3157();
+    o.elements = buildUnnamed3162();
   }
   buildCounterStringList--;
   return o;
 }
 
 checkStringList(api.StringList o) {
   buildCounterStringList++;
   if (buildCounterStringList < 3) {
-    checkUnnamed3157(o.elements);
+    checkUnnamed3162(o.elements);
   }
   buildCounterStringList--;
 }
 
-buildUnnamed3158() {
+buildUnnamed3163() {
+  var o = new core.List<api.Parameter>();
+  o.add(buildParameter());
+  o.add(buildParameter());
+  return o;
+}
+
+checkUnnamed3163(core.List<api.Parameter> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  checkParameter(o[0]);
+  checkParameter(o[1]);
+}
+
+core.int buildCounterStructuredMessage = 0;
+buildStructuredMessage() {
+  var o = new api.StructuredMessage();
+  buildCounterStructuredMessage++;
+  if (buildCounterStructuredMessage < 3) {
+    o.messageKey = "foo";
+    o.messageText = "foo";
+    o.parameters = buildUnnamed3163();
+  }
+  buildCounterStructuredMessage--;
+  return o;
+}
+
+checkStructuredMessage(api.StructuredMessage o) {
+  buildCounterStructuredMessage++;
+  if (buildCounterStructuredMessage < 3) {
+    unittest.expect(o.messageKey, unittest.equals('foo'));
+    unittest.expect(o.messageText, unittest.equals('foo'));
+    checkUnnamed3163(o.parameters);
+  }
+  buildCounterStructuredMessage--;
+}
+
+buildUnnamed3164() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3158(core.List<core.String> o) {
+checkUnnamed3164(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
 core.int buildCounterTaskRunnerSettings = 0;
 buildTaskRunnerSettings() {
   var o = new api.TaskRunnerSettings();
   buildCounterTaskRunnerSettings++;
   if (buildCounterTaskRunnerSettings < 3) {
     o.alsologtostderr = true;
     o.baseTaskDir = "foo";
     o.baseUrl = "foo";
     o.commandlinesFileName = "foo";
     o.continueOnException = true;
     o.dataflowApiVersion = "foo";
     o.harnessCommand = "foo";
     o.languageHint = "foo";
     o.logDir = "foo";
     o.logToSerialconsole = true;
     o.logUploadLocation = "foo";
-    o.oauthScopes = buildUnnamed3158();
+    o.oauthScopes = buildUnnamed3164();
     o.parallelWorkerSettings = buildWorkerSettings();
     o.streamingWorkerMainClass = "foo";
     o.taskGroup = "foo";
     o.taskUser = "foo";
     o.tempStoragePrefix = "foo";
     o.vmId = "foo";
     o.workflowFileName = "foo";
   }
   buildCounterTaskRunnerSettings--;
   return o;
 }
 
 checkTaskRunnerSettings(api.TaskRunnerSettings o) {
   buildCounterTaskRunnerSettings++;
   if (buildCounterTaskRunnerSettings < 3) {
     unittest.expect(o.alsologtostderr, unittest.isTrue);
     unittest.expect(o.baseTaskDir, unittest.equals('foo'));
     unittest.expect(o.baseUrl, unittest.equals('foo'));
     unittest.expect(o.commandlinesFileName, unittest.equals('foo'));
     unittest.expect(o.continueOnException, unittest.isTrue);
     unittest.expect(o.dataflowApiVersion, unittest.equals('foo'));
     unittest.expect(o.harnessCommand, unittest.equals('foo'));
     unittest.expect(o.languageHint, unittest.equals('foo'));
     unittest.expect(o.logDir, unittest.equals('foo'));
     unittest.expect(o.logToSerialconsole, unittest.isTrue);
     unittest.expect(o.logUploadLocation, unittest.equals('foo'));
-    checkUnnamed3158(o.oauthScopes);
+    checkUnnamed3164(o.oauthScopes);
     checkWorkerSettings(o.parallelWorkerSettings);
     unittest.expect(o.streamingWorkerMainClass, unittest.equals('foo'));
     unittest.expect(o.taskGroup, unittest.equals('foo'));
     unittest.expect(o.taskUser, unittest.equals('foo'));
     unittest.expect(o.tempStoragePrefix, unittest.equals('foo'));
     unittest.expect(o.vmId, unittest.equals('foo'));
     unittest.expect(o.workflowFileName, unittest.equals('foo'));
   }
   buildCounterTaskRunnerSettings--;
 }
 
-buildUnnamed3159() {
+buildUnnamed3165() {
   var o = new core.List<api.ParameterMetadata>();
   o.add(buildParameterMetadata());
   o.add(buildParameterMetadata());
   return o;
 }
 
-checkUnnamed3159(core.List<api.ParameterMetadata> o) {
+checkUnnamed3165(core.List<api.ParameterMetadata> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkParameterMetadata(o[0]);
   checkParameterMetadata(o[1]);
 }
 
 core.int buildCounterTemplateMetadata = 0;
 buildTemplateMetadata() {
   var o = new api.TemplateMetadata();
   buildCounterTemplateMetadata++;
   if (buildCounterTemplateMetadata < 3) {
     o.bypassTempDirValidation = true;
     o.description = "foo";
     o.name = "foo";
-    o.parameters = buildUnnamed3159();
+    o.parameters = buildUnnamed3165();
   }
   buildCounterTemplateMetadata--;
   return o;
 }
 
 checkTemplateMetadata(api.TemplateMetadata o) {
   buildCounterTemplateMetadata++;
   if (buildCounterTemplateMetadata < 3) {
     unittest.expect(o.bypassTempDirValidation, unittest.isTrue);
     unittest.expect(o.description, unittest.equals('foo'));
     unittest.expect(o.name, unittest.equals('foo'));
-    checkUnnamed3159(o.parameters);
+    checkUnnamed3165(o.parameters);
   }
   buildCounterTemplateMetadata--;
 }
 
-buildUnnamed3160() {
+buildUnnamed3166() {
   var o = new core.List<api.ComputationTopology>();
   o.add(buildComputationTopology());
   o.add(buildComputationTopology());
   return o;
 }
 
-checkUnnamed3160(core.List<api.ComputationTopology> o) {
+checkUnnamed3166(core.List<api.ComputationTopology> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkComputationTopology(o[0]);
   checkComputationTopology(o[1]);
 }
 
-buildUnnamed3161() {
+buildUnnamed3167() {
   var o = new core.List<api.DataDiskAssignment>();
   o.add(buildDataDiskAssignment());
   o.add(buildDataDiskAssignment());
   return o;
 }
 
-checkUnnamed3161(core.List<api.DataDiskAssignment> o) {
+checkUnnamed3167(core.List<api.DataDiskAssignment> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkDataDiskAssignment(o[0]);
   checkDataDiskAssignment(o[1]);
 }
 
-buildUnnamed3162() {
+buildUnnamed3168() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3162(core.Map<core.String, core.String> o) {
+checkUnnamed3168(core.Map<core.String, core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o["x"], unittest.equals('foo'));
   unittest.expect(o["y"], unittest.equals('foo'));
 }
 
 core.int buildCounterTopologyConfig = 0;
 buildTopologyConfig() {
   var o = new api.TopologyConfig();
   buildCounterTopologyConfig++;
   if (buildCounterTopologyConfig < 3) {
-    o.computations = buildUnnamed3160();
-    o.dataDiskAssignments = buildUnnamed3161();
+    o.computations = buildUnnamed3166();
+    o.dataDiskAssignments = buildUnnamed3167();
     o.forwardingKeyBits = 42;
     o.persistentStateVersion = 42;
-    o.userStageToComputationNameMap = buildUnnamed3162();
+    o.userStageToComputationNameMap = buildUnnamed3168();
   }
   buildCounterTopologyConfig--;
   return o;
 }
 
 checkTopologyConfig(api.TopologyConfig o) {
   buildCounterTopologyConfig++;
   if (buildCounterTopologyConfig < 3) {
-    checkUnnamed3160(o.computations);
-    checkUnnamed3161(o.dataDiskAssignments);
+    checkUnnamed3166(o.computations);
+    checkUnnamed3167(o.dataDiskAssignments);
     unittest.expect(o.forwardingKeyBits, unittest.equals(42));
     unittest.expect(o.persistentStateVersion, unittest.equals(42));
-    checkUnnamed3162(o.userStageToComputationNameMap);
+    checkUnnamed3168(o.userStageToComputationNameMap);
   }
   buildCounterTopologyConfig--;
 }
 
-buildUnnamed3163() {
+buildUnnamed3169() {
   var o = new core.List<api.DisplayData>();
   o.add(buildDisplayData());
   o.add(buildDisplayData());
   return o;
 }
 
-checkUnnamed3163(core.List<api.DisplayData> o) {
+checkUnnamed3169(core.List<api.DisplayData> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkDisplayData(o[0]);
   checkDisplayData(o[1]);
 }
 
-buildUnnamed3164() {
+buildUnnamed3170() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3164(core.List<core.String> o) {
+checkUnnamed3170(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
-buildUnnamed3165() {
+buildUnnamed3171() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3165(core.List<core.String> o) {
+checkUnnamed3171(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
 core.int buildCounterTransformSummary = 0;
 buildTransformSummary() {
   var o = new api.TransformSummary();
   buildCounterTransformSummary++;
   if (buildCounterTransformSummary < 3) {
-    o.displayData = buildUnnamed3163();
+    o.displayData = buildUnnamed3169();
     o.id = "foo";
-    o.inputCollectionName = buildUnnamed3164();
+    o.inputCollectionName = buildUnnamed3170();
     o.kind = "foo";
     o.name = "foo";
-    o.outputCollectionName = buildUnnamed3165();
+    o.outputCollectionName = buildUnnamed3171();
   }
   buildCounterTransformSummary--;
   return o;
 }
 
 checkTransformSummary(api.TransformSummary o) {
   buildCounterTransformSummary++;
   if (buildCounterTransformSummary < 3) {
-    checkUnnamed3163(o.displayData);
+    checkUnnamed3169(o.displayData);
     unittest.expect(o.id, unittest.equals('foo'));
-    checkUnnamed3164(o.inputCollectionName);
+    checkUnnamed3170(o.inputCollectionName);
     unittest.expect(o.kind, unittest.equals('foo'));
     unittest.expect(o.name, unittest.equals('foo'));
-    checkUnnamed3165(o.outputCollectionName);
+    checkUnnamed3171(o.outputCollectionName);
   }
   buildCounterTransformSummary--;
 }
 
-buildUnnamed3166() {
+buildUnnamed3172() {
   var o = new core.List<api.Package>();
   o.add(buildPackage());
   o.add(buildPackage());
   return o;
 }
 
-checkUnnamed3166(core.List<api.Package> o) {
+checkUnnamed3172(core.List<api.Package> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkPackage(o[0]);
   checkPackage(o[1]);
 }
 
 core.int buildCounterWorkItem = 0;
 buildWorkItem() {
   var o = new api.WorkItem();
   buildCounterWorkItem++;
   if (buildCounterWorkItem < 3) {
     o.configuration = "foo";
     o.id = "foo";
     o.initialReportIndex = "foo";
     o.jobId = "foo";
     o.leaseExpireTime = "foo";
     o.mapTask = buildMapTask();
-    o.packages = buildUnnamed3166();
+    o.packages = buildUnnamed3172();
     o.projectId = "foo";
     o.reportStatusInterval = "foo";
     o.seqMapTask = buildSeqMapTask();
     o.shellTask = buildShellTask();
     o.sourceOperationTask = buildSourceOperationRequest();
     o.streamingComputationTask = buildStreamingComputationTask();
     o.streamingConfigTask = buildStreamingConfigTask();
     o.streamingSetupTask = buildStreamingSetupTask();
   }
   buildCounterWorkItem--;
   return o;
 }
 
 checkWorkItem(api.WorkItem o) {
   buildCounterWorkItem++;
   if (buildCounterWorkItem < 3) {
     unittest.expect(o.configuration, unittest.equals('foo'));
     unittest.expect(o.id, unittest.equals('foo'));
     unittest.expect(o.initialReportIndex, unittest.equals('foo'));
     unittest.expect(o.jobId, unittest.equals('foo'));
     unittest.expect(o.leaseExpireTime, unittest.equals('foo'));
     checkMapTask(o.mapTask);
-    checkUnnamed3166(o.packages);
+    checkUnnamed3172(o.packages);
     unittest.expect(o.projectId, unittest.equals('foo'));
     unittest.expect(o.reportStatusInterval, unittest.equals('foo'));
     checkSeqMapTask(o.seqMapTask);
     checkShellTask(o.shellTask);
     checkSourceOperationRequest(o.sourceOperationTask);
     checkStreamingComputationTask(o.streamingComputationTask);
     checkStreamingConfigTask(o.streamingConfigTask);
     checkStreamingSetupTask(o.streamingSetupTask);
   }
   buildCounterWorkItem--;
 }
 
-buildUnnamed3167() {
+buildUnnamed3173() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3167(core.Map<core.String, core.Object> o) {
+checkUnnamed3173(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted41 = (o["x"]) as core.Map; unittest.expect(casted41, unittest.hasLength(3)); unittest.expect(casted41["list"], unittest.equals([1, 2, 3])); unittest.expect(casted41["bool"], unittest.equals(true)); unittest.expect(casted41["string"], unittest.equals('foo')); 
-  var casted42 = (o["y"]) as core.Map; unittest.expect(casted42, unittest.hasLength(3)); unittest.expect(casted42["list"], unittest.equals([1, 2, 3])); unittest.expect(casted42["bool"], unittest.equals(true)); unittest.expect(casted42["string"], unittest.equals('foo')); 
+  var casted42 = (o["x"]) as core.Map; unittest.expect(casted42, unittest.hasLength(3)); unittest.expect(casted42["list"], unittest.equals([1, 2, 3])); unittest.expect(casted42["bool"], unittest.equals(true)); unittest.expect(casted42["string"], unittest.equals('foo')); 
+  var casted43 = (o["y"]) as core.Map; unittest.expect(casted43, unittest.hasLength(3)); unittest.expect(casted43["list"], unittest.equals([1, 2, 3])); unittest.expect(casted43["bool"], unittest.equals(true)); unittest.expect(casted43["string"], unittest.equals('foo')); 
 }
 
-buildUnnamed3168() {
+buildUnnamed3174() {
   var o = new core.List<api.MetricShortId>();
   o.add(buildMetricShortId());
   o.add(buildMetricShortId());
   return o;
 }
 
-checkUnnamed3168(core.List<api.MetricShortId> o) {
+checkUnnamed3174(core.List<api.MetricShortId> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkMetricShortId(o[0]);
   checkMetricShortId(o[1]);
 }
 
 core.int buildCounterWorkItemServiceState = 0;
 buildWorkItemServiceState() {
   var o = new api.WorkItemServiceState();
   buildCounterWorkItemServiceState++;
   if (buildCounterWorkItemServiceState < 3) {
-    o.harnessData = buildUnnamed3167();
+    o.harnessData = buildUnnamed3173();
     o.leaseExpireTime = "foo";
-    o.metricShortId = buildUnnamed3168();
+    o.metricShortId = buildUnnamed3174();
     o.nextReportIndex = "foo";
     o.reportStatusInterval = "foo";
     o.splitRequest = buildApproximateSplitRequest();
     o.suggestedStopPoint = buildApproximateProgress();
     o.suggestedStopPosition = buildPosition();
   }
   buildCounterWorkItemServiceState--;
   return o;
 }
 
 checkWorkItemServiceState(api.WorkItemServiceState o) {
   buildCounterWorkItemServiceState++;
   if (buildCounterWorkItemServiceState < 3) {
-    checkUnnamed3167(o.harnessData);
+    checkUnnamed3173(o.harnessData);
     unittest.expect(o.leaseExpireTime, unittest.equals('foo'));
-    checkUnnamed3168(o.metricShortId);
+    checkUnnamed3174(o.metricShortId);
     unittest.expect(o.nextReportIndex, unittest.equals('foo'));
     unittest.expect(o.reportStatusInterval, unittest.equals('foo'));
     checkApproximateSplitRequest(o.splitRequest);
     checkApproximateProgress(o.suggestedStopPoint);
     checkPosition(o.suggestedStopPosition);
   }
   buildCounterWorkItemServiceState--;
 }
 
-buildUnnamed3169() {
+buildUnnamed3175() {
   var o = new core.List<api.CounterUpdate>();
   o.add(buildCounterUpdate());
   o.add(buildCounterUpdate());
   return o;
 }
 
-checkUnnamed3169(core.List<api.CounterUpdate> o) {
+checkUnnamed3175(core.List<api.CounterUpdate> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkCounterUpdate(o[0]);
   checkCounterUpdate(o[1]);
 }
 
-buildUnnamed3170() {
+buildUnnamed3176() {
   var o = new core.List<api.Status>();
   o.add(buildStatus());
   o.add(buildStatus());
   return o;
 }
 
-checkUnnamed3170(core.List<api.Status> o) {
+checkUnnamed3176(core.List<api.Status> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStatus(o[0]);
   checkStatus(o[1]);
 }
 
-buildUnnamed3171() {
+buildUnnamed3177() {
   var o = new core.List<api.MetricUpdate>();
   o.add(buildMetricUpdate());
   o.add(buildMetricUpdate());
   return o;
 }
 
-checkUnnamed3171(core.List<api.MetricUpdate> o) {
+checkUnnamed3177(core.List<api.MetricUpdate> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkMetricUpdate(o[0]);
   checkMetricUpdate(o[1]);
 }
 
 core.int buildCounterWorkItemStatus = 0;
 buildWorkItemStatus() {
   var o = new api.WorkItemStatus();
   buildCounterWorkItemStatus++;
   if (buildCounterWorkItemStatus < 3) {
     o.completed = true;
-    o.counterUpdates = buildUnnamed3169();
+    o.counterUpdates = buildUnnamed3175();
     o.dynamicSourceSplit = buildDynamicSourceSplit();
-    o.errors = buildUnnamed3170();
-    o.metricUpdates = buildUnnamed3171();
+    o.errors = buildUnnamed3176();
+    o.metricUpdates = buildUnnamed3177();
     o.progress = buildApproximateProgress();
     o.reportIndex = "foo";
     o.reportedProgress = buildApproximateReportedProgress();
     o.requestedLeaseDuration = "foo";
     o.sourceFork = buildSourceFork();
     o.sourceOperationResponse = buildSourceOperationResponse();
     o.stopPosition = buildPosition();
     o.workItemId = "foo";
   }
   buildCounterWorkItemStatus--;
   return o;
 }
 
 checkWorkItemStatus(api.WorkItemStatus o) {
   buildCounterWorkItemStatus++;
   if (buildCounterWorkItemStatus < 3) {
     unittest.expect(o.completed, unittest.isTrue);
-    checkUnnamed3169(o.counterUpdates);
+    checkUnnamed3175(o.counterUpdates);
     checkDynamicSourceSplit(o.dynamicSourceSplit);
-    checkUnnamed3170(o.errors);
-    checkUnnamed3171(o.metricUpdates);
+    checkUnnamed3176(o.errors);
+    checkUnnamed3177(o.metricUpdates);
     checkApproximateProgress(o.progress);
     unittest.expect(o.reportIndex, unittest.equals('foo'));
     checkApproximateReportedProgress(o.reportedProgress);
     unittest.expect(o.requestedLeaseDuration, unittest.equals('foo'));
     checkSourceFork(o.sourceFork);
     checkSourceOperationResponse(o.sourceOperationResponse);
     checkPosition(o.stopPosition);
     unittest.expect(o.workItemId, unittest.equals('foo'));
   }
   buildCounterWorkItemStatus--;
 }
 
-buildUnnamed3172() {
+buildUnnamed3178() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3172(core.Map<core.String, core.Object> o) {
+checkUnnamed3178(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted43 = (o["x"]) as core.Map; unittest.expect(casted43, unittest.hasLength(3)); unittest.expect(casted43["list"], unittest.equals([1, 2, 3])); unittest.expect(casted43["bool"], unittest.equals(true)); unittest.expect(casted43["string"], unittest.equals('foo')); 
-  var casted44 = (o["y"]) as core.Map; unittest.expect(casted44, unittest.hasLength(3)); unittest.expect(casted44["list"], unittest.equals([1, 2, 3])); unittest.expect(casted44["bool"], unittest.equals(true)); unittest.expect(casted44["string"], unittest.equals('foo')); 
+  var casted44 = (o["x"]) as core.Map; unittest.expect(casted44, unittest.hasLength(3)); unittest.expect(casted44["list"], unittest.equals([1, 2, 3])); unittest.expect(casted44["bool"], unittest.equals(true)); unittest.expect(casted44["string"], unittest.equals('foo')); 
+  var casted45 = (o["y"]) as core.Map; unittest.expect(casted45, unittest.hasLength(3)); unittest.expect(casted45["list"], unittest.equals([1, 2, 3])); unittest.expect(casted45["bool"], unittest.equals(true)); unittest.expect(casted45["string"], unittest.equals('foo')); 
 }
 
-buildUnnamed3173() {
+buildUnnamed3179() {
   var o = new core.List<core.Map<core.String, core.Object>>();
-  o.add(buildUnnamed3172());
-  o.add(buildUnnamed3172());
+  o.add(buildUnnamed3178());
+  o.add(buildUnnamed3178());
   return o;
 }
 
-checkUnnamed3173(core.List<core.Map<core.String, core.Object>> o) {
+checkUnnamed3179(core.List<core.Map<core.String, core.Object>> o) {
   unittest.expect(o, unittest.hasLength(2));
-  checkUnnamed3172(o[0]);
-  checkUnnamed3172(o[1]);
+  checkUnnamed3178(o[0]);
+  checkUnnamed3178(o[1]);
 }
 
 core.int buildCounterWorkerHealthReport = 0;
 buildWorkerHealthReport() {
   var o = new api.WorkerHealthReport();
   buildCounterWorkerHealthReport++;
   if (buildCounterWorkerHealthReport < 3) {
-    o.pods = buildUnnamed3173();
+    o.pods = buildUnnamed3179();
     o.reportInterval = "foo";
     o.vmIsHealthy = true;
     o.vmStartupTime = "foo";
   }
   buildCounterWorkerHealthReport--;
   return o;
 }
 
 checkWorkerHealthReport(api.WorkerHealthReport o) {
   buildCounterWorkerHealthReport++;
   if (buildCounterWorkerHealthReport < 3) {
-    checkUnnamed3173(o.pods);
+    checkUnnamed3179(o.pods);
     unittest.expect(o.reportInterval, unittest.equals('foo'));
     unittest.expect(o.vmIsHealthy, unittest.isTrue);
     unittest.expect(o.vmStartupTime, unittest.equals('foo'));
   }
   buildCounterWorkerHealthReport--;
 }
 
 core.int buildCounterWorkerHealthReportResponse = 0;
 buildWorkerHealthReportResponse() {
   var o = new api.WorkerHealthReportResponse();
   buildCounterWorkerHealthReportResponse++;
   if (buildCounterWorkerHealthReportResponse < 3) {
     o.reportInterval = "foo";
   }
   buildCounterWorkerHealthReportResponse--;
   return o;
 }
 
 checkWorkerHealthReportResponse(api.WorkerHealthReportResponse o) {
   buildCounterWorkerHealthReportResponse++;
   if (buildCounterWorkerHealthReportResponse < 3) {
     unittest.expect(o.reportInterval, unittest.equals('foo'));
   }
   buildCounterWorkerHealthReportResponse--;
 }
 
-buildUnnamed3174() {
+buildUnnamed3180() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3174(core.Map<core.String, core.String> o) {
+checkUnnamed3180(core.Map<core.String, core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o["x"], unittest.equals('foo'));
   unittest.expect(o["y"], unittest.equals('foo'));
 }
 
 core.int buildCounterWorkerMessage = 0;
 buildWorkerMessage() {
   var o = new api.WorkerMessage();
   buildCounterWorkerMessage++;
   if (buildCounterWorkerMessage < 3) {
-    o.labels = buildUnnamed3174();
+    o.labels = buildUnnamed3180();
     o.time = "foo";
     o.workerHealthReport = buildWorkerHealthReport();
     o.workerMessageCode = buildWorkerMessageCode();
     o.workerMetrics = buildResourceUtilizationReport();
   }
   buildCounterWorkerMessage--;
   return o;
 }
 
 checkWorkerMessage(api.WorkerMessage o) {
   buildCounterWorkerMessage++;
   if (buildCounterWorkerMessage < 3) {
-    checkUnnamed3174(o.labels);
+    checkUnnamed3180(o.labels);
     unittest.expect(o.time, unittest.equals('foo'));
     checkWorkerHealthReport(o.workerHealthReport);
     checkWorkerMessageCode(o.workerMessageCode);
     checkResourceUtilizationReport(o.workerMetrics);
   }
   buildCounterWorkerMessage--;
 }
 
-buildUnnamed3175() {
+buildUnnamed3181() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3175(core.Map<core.String, core.Object> o) {
+checkUnnamed3181(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted45 = (o["x"]) as core.Map; unittest.expect(casted45, unittest.hasLength(3)); unittest.expect(casted45["list"], unittest.equals([1, 2, 3])); unittest.expect(casted45["bool"], unittest.equals(true)); unittest.expect(casted45["string"], unittest.equals('foo')); 
-  var casted46 = (o["y"]) as core.Map; unittest.expect(casted46, unittest.hasLength(3)); unittest.expect(casted46["list"], unittest.equals([1, 2, 3])); unittest.expect(casted46["bool"], unittest.equals(true)); unittest.expect(casted46["string"], unittest.equals('foo')); 
+  var casted46 = (o["x"]) as core.Map; unittest.expect(casted46, unittest.hasLength(3)); unittest.expect(casted46["list"], unittest.equals([1, 2, 3])); unittest.expect(casted46["bool"], unittest.equals(true)); unittest.expect(casted46["string"], unittest.equals('foo')); 
+  var casted47 = (o["y"]) as core.Map; unittest.expect(casted47, unittest.hasLength(3)); unittest.expect(casted47["list"], unittest.equals([1, 2, 3])); unittest.expect(casted47["bool"], unittest.equals(true)); unittest.expect(casted47["string"], unittest.equals('foo')); 
 }
 
 core.int buildCounterWorkerMessageCode = 0;
 buildWorkerMessageCode() {
   var o = new api.WorkerMessageCode();
   buildCounterWorkerMessageCode++;
   if (buildCounterWorkerMessageCode < 3) {
     o.code = "foo";
-    o.parameters = buildUnnamed3175();
+    o.parameters = buildUnnamed3181();
   }
   buildCounterWorkerMessageCode--;
   return o;
 }
 
 checkWorkerMessageCode(api.WorkerMessageCode o) {
   buildCounterWorkerMessageCode++;
   if (buildCounterWorkerMessageCode < 3) {
     unittest.expect(o.code, unittest.equals('foo'));
-    checkUnnamed3175(o.parameters);
+    checkUnnamed3181(o.parameters);
   }
   buildCounterWorkerMessageCode--;
 }
 
 core.int buildCounterWorkerMessageResponse = 0;
 buildWorkerMessageResponse() {
   var o = new api.WorkerMessageResponse();
   buildCounterWorkerMessageResponse++;
   if (buildCounterWorkerMessageResponse < 3) {
     o.workerHealthReportResponse = buildWorkerHealthReportResponse();
     o.workerMetricsResponse = buildResourceUtilizationReportResponse();
   }
   buildCounterWorkerMessageResponse--;
   return o;
 }
 
 checkWorkerMessageResponse(api.WorkerMessageResponse o) {
   buildCounterWorkerMessageResponse++;
   if (buildCounterWorkerMessageResponse < 3) {
     checkWorkerHealthReportResponse(o.workerHealthReportResponse);
     checkResourceUtilizationReportResponse(o.workerMetricsResponse);
   }
   buildCounterWorkerMessageResponse--;
 }
 
-buildUnnamed3176() {
+buildUnnamed3182() {
   var o = new core.List<api.Disk>();
   o.add(buildDisk());
   o.add(buildDisk());
   return o;
 }
 
-checkUnnamed3176(core.List<api.Disk> o) {
+checkUnnamed3182(core.List<api.Disk> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkDisk(o[0]);
   checkDisk(o[1]);
 }
 
-buildUnnamed3177() {
+buildUnnamed3183() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3177(core.Map<core.String, core.String> o) {
+checkUnnamed3183(core.Map<core.String, core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o["x"], unittest.equals('foo'));
   unittest.expect(o["y"], unittest.equals('foo'));
 }
 
-buildUnnamed3178() {
+buildUnnamed3184() {
   var o = new core.List<api.Package>();
   o.add(buildPackage());
   o.add(buildPackage());
   return o;
 }
 
-checkUnnamed3178(core.List<api.Package> o) {
+checkUnnamed3184(core.List<api.Package> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkPackage(o[0]);
   checkPackage(o[1]);
 }
 
-buildUnnamed3179() {
+buildUnnamed3185() {
   var o = new core.Map<core.String, core.Object>();
   o["x"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   o["y"] = {'list' : [1, 2, 3], 'bool' : true, 'string' : 'foo'};
   return o;
 }
 
-checkUnnamed3179(core.Map<core.String, core.Object> o) {
+checkUnnamed3185(core.Map<core.String, core.Object> o) {
   unittest.expect(o, unittest.hasLength(2));
-  var casted47 = (o["x"]) as core.Map; unittest.expect(casted47, unittest.hasLength(3)); unittest.expect(casted47["list"], unittest.equals([1, 2, 3])); unittest.expect(casted47["bool"], unittest.equals(true)); unittest.expect(casted47["string"], unittest.equals('foo')); 
-  var casted48 = (o["y"]) as core.Map; unittest.expect(casted48, unittest.hasLength(3)); unittest.expect(casted48["list"], unittest.equals([1, 2, 3])); unittest.expect(casted48["bool"], unittest.equals(true)); unittest.expect(casted48["string"], unittest.equals('foo')); 
+  var casted48 = (o["x"]) as core.Map; unittest.expect(casted48, unittest.hasLength(3)); unittest.expect(casted48["list"], unittest.equals([1, 2, 3])); unittest.expect(casted48["bool"], unittest.equals(true)); unittest.expect(casted48["string"], unittest.equals('foo')); 
+  var casted49 = (o["y"]) as core.Map; unittest.expect(casted49, unittest.hasLength(3)); unittest.expect(casted49["list"], unittest.equals([1, 2, 3])); unittest.expect(casted49["bool"], unittest.equals(true)); unittest.expect(casted49["string"], unittest.equals('foo')); 
 }
 
 core.int buildCounterWorkerPool = 0;
 buildWorkerPool() {
   var o = new api.WorkerPool();
   buildCounterWorkerPool++;
   if (buildCounterWorkerPool < 3) {
     o.autoscalingSettings = buildAutoscalingSettings();
-    o.dataDisks = buildUnnamed3176();
+    o.dataDisks = buildUnnamed3182();
     o.defaultPackageSet = "foo";
     o.diskSizeGb = 42;
     o.diskSourceImage = "foo";
     o.diskType = "foo";
     o.ipConfiguration = "foo";
     o.kind = "foo";
     o.machineType = "foo";
-    o.metadata = buildUnnamed3177();
+    o.metadata = buildUnnamed3183();
     o.network = "foo";
     o.numThreadsPerWorker = 42;
     o.numWorkers = 42;
     o.onHostMaintenance = "foo";
-    o.packages = buildUnnamed3178();
-    o.poolArgs = buildUnnamed3179();
+    o.packages = buildUnnamed3184();
+    o.poolArgs = buildUnnamed3185();
     o.subnetwork = "foo";
     o.taskrunnerSettings = buildTaskRunnerSettings();
     o.teardownPolicy = "foo";
     o.workerHarnessContainerImage = "foo";
     o.zone = "foo";
   }
   buildCounterWorkerPool--;
   return o;
 }
 
 checkWorkerPool(api.WorkerPool o) {
   buildCounterWorkerPool++;
   if (buildCounterWorkerPool < 3) {
     checkAutoscalingSettings(o.autoscalingSettings);
-    checkUnnamed3176(o.dataDisks);
+    checkUnnamed3182(o.dataDisks);
     unittest.expect(o.defaultPackageSet, unittest.equals('foo'));
     unittest.expect(o.diskSizeGb, unittest.equals(42));
     unittest.expect(o.diskSourceImage, unittest.equals('foo'));
     unittest.expect(o.diskType, unittest.equals('foo'));
     unittest.expect(o.ipConfiguration, unittest.equals('foo'));
     unittest.expect(o.kind, unittest.equals('foo'));
     unittest.expect(o.machineType, unittest.equals('foo'));
-    checkUnnamed3177(o.metadata);
+    checkUnnamed3183(o.metadata);
     unittest.expect(o.network, unittest.equals('foo'));
     unittest.expect(o.numThreadsPerWorker, unittest.equals(42));
     unittest.expect(o.numWorkers, unittest.equals(42));
     unittest.expect(o.onHostMaintenance, unittest.equals('foo'));
-    checkUnnamed3178(o.packages);
-    checkUnnamed3179(o.poolArgs);
+    checkUnnamed3184(o.packages);
+    checkUnnamed3185(o.poolArgs);
     unittest.expect(o.subnetwork, unittest.equals('foo'));
     checkTaskRunnerSettings(o.taskrunnerSettings);
     unittest.expect(o.teardownPolicy, unittest.equals('foo'));
     unittest.expect(o.workerHarnessContainerImage, unittest.equals('foo'));
     unittest.expect(o.zone, unittest.equals('foo'));
   }
   buildCounterWorkerPool--;
 }
 
 core.int buildCounterWorkerSettings = 0;
@@ skipping 68 matching lines @@
 
   unittest.group("obj-schema-ApproximateSplitRequest", () {
     unittest.test("to-json--from-json", () {
       var o = buildApproximateSplitRequest();
       var od = new api.ApproximateSplitRequest.fromJson(o.toJson());
       checkApproximateSplitRequest(od);
     });
   });
 
 
+  unittest.group("obj-schema-AutoscalingEvent", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildAutoscalingEvent();
+      var od = new api.AutoscalingEvent.fromJson(o.toJson());
+      checkAutoscalingEvent(od);
+    });
+  });
+
+
   unittest.group("obj-schema-AutoscalingSettings", () {
     unittest.test("to-json--from-json", () {
       var o = buildAutoscalingSettings();
       var od = new api.AutoscalingSettings.fromJson(o.toJson());
       checkAutoscalingSettings(od);
     });
   });
 
 
   unittest.group("obj-schema-CPUTime", () {
@@ skipping 151 matching lines @@
 
   unittest.group("obj-schema-Environment", () {
     unittest.test("to-json--from-json", () {
       var o = buildEnvironment();
       var od = new api.Environment.fromJson(o.toJson());
       checkEnvironment(od);
     });
   });
 
 
+  unittest.group("obj-schema-ExecutionStageState", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildExecutionStageState();
+      var od = new api.ExecutionStageState.fromJson(o.toJson());
+      checkExecutionStageState(od);
+    });
+  });
+
+
   unittest.group("obj-schema-ExecutionStageSummary", () {
     unittest.test("to-json--from-json", () {
       var o = buildExecutionStageSummary();
       var od = new api.ExecutionStageSummary.fromJson(o.toJson());
       checkExecutionStageSummary(od);
     });
   });
 
 
   unittest.group("obj-schema-FailedLocation", () {
@@ skipping 295 matching lines @@
 
   unittest.group("obj-schema-ParallelInstruction", () {
     unittest.test("to-json--from-json", () {
       var o = buildParallelInstruction();
       var od = new api.ParallelInstruction.fromJson(o.toJson());
       checkParallelInstruction(od);
     });
   });
 
 
+  unittest.group("obj-schema-Parameter", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildParameter();
+      var od = new api.Parameter.fromJson(o.toJson());
+      checkParameter(od);
+    });
+  });
+
+
   unittest.group("obj-schema-ParameterMetadata", () {
     unittest.test("to-json--from-json", () {
       var o = buildParameterMetadata();
       var od = new api.ParameterMetadata.fromJson(o.toJson());
       checkParameterMetadata(od);
     });
   });
 
 
   unittest.group("obj-schema-PartialGroupByKeyInstruction", () {
@@ skipping 394 matching lines @@
 
   unittest.group("obj-schema-StringList", () {
     unittest.test("to-json--from-json", () {
       var o = buildStringList();
       var od = new api.StringList.fromJson(o.toJson());
       checkStringList(od);
     });
   });
 
 
+  unittest.group("obj-schema-StructuredMessage", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildStructuredMessage();
+      var od = new api.StructuredMessage.fromJson(o.toJson());
+      checkStructuredMessage(od);
+    });
+  });
+
+
   unittest.group("obj-schema-TaskRunnerSettings", () {
     unittest.test("to-json--from-json", () {
       var o = buildTaskRunnerSettings();
       var od = new api.TaskRunnerSettings.fromJson(o.toJson());
       checkTaskRunnerSettings(od);
     });
   });
 
 
   unittest.group("obj-schema-TemplateMetadata", () {
@@ skipping 181 matching lines @@
   });
 
 
   unittest.group("resource-ProjectsJobsResourceApi", () {
     unittest.test("method--create", () {
 
       var mock = new HttpServerMock();
       api.ProjectsJobsResourceApi res = new api.DataflowApi(mock).projects.jobs;
       var arg_request = buildJob();
       var arg_projectId = "foo";
+      var arg_view = "foo";
       var arg_location = "foo";
       var arg_replaceJobId = "foo";
-      var arg_view = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.Job.fromJson(json);
         checkJob(obj);
 
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
         pathOffset += 1;
@@ skipping 16 matching lines @@
           if (n == "false") return false;
           if (n == null) return null;
           throw new core.ArgumentError("Invalid boolean: $n");
         }
         if (query.length > 0) {
           for (var part in query.split("&")) {
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
+        unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
         unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
         unittest.expect(queryMap["replaceJobId"].first, unittest.equals(arg_replaceJobId));
-        unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildJob());
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
-      res.create(arg_request, arg_projectId, location: arg_location, replaceJobId: arg_replaceJobId, view: arg_view).then(unittest.expectAsync(((api.Job response) {
+      res.create(arg_request, arg_projectId, view: arg_view, location: arg_location, replaceJobId: arg_replaceJobId).then(unittest.expectAsync(((api.Job response) {
         checkJob(response);
       })));
     });
 
     unittest.test("method--get", () {
 
       var mock = new HttpServerMock();
       api.ProjectsJobsResourceApi res = new api.DataflowApi(mock).projects.jobs;
       var arg_projectId = "foo";
       var arg_jobId = "foo";
+      var arg_location = "foo";
       var arg_view = "foo";
-      var arg_location = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
         pathOffset += 1;
         unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
         pathOffset += 14;
         index = path.indexOf("/jobs/", pathOffset);
@@ skipping 16 matching lines @@
           if (n == "false") return false;
           if (n == null) return null;
           throw new core.ArgumentError("Invalid boolean: $n");
         }
         if (query.length > 0) {
           for (var part in query.split("&")) {
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
+        unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
         unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
-        unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildJob());
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
-      res.get(arg_projectId, arg_jobId, view: arg_view, location: arg_location).then(unittest.expectAsync(((api.Job response) {
+      res.get(arg_projectId, arg_jobId, location: arg_location, view: arg_view).then(unittest.expectAsync(((api.Job response) {
         checkJob(response);
       })));
     });
 
     unittest.test("method--getMetrics", () {
 
       var mock = new HttpServerMock();
       api.ProjectsJobsResourceApi res = new api.DataflowApi(mock).projects.jobs;
       var arg_projectId = "foo";
       var arg_jobId = "foo";
@@ skipping 309 matching lines @@
   });
 
 
   unittest.group("resource-ProjectsJobsMessagesResourceApi", () {
     unittest.test("method--list", () {
 
       var mock = new HttpServerMock();
       api.ProjectsJobsMessagesResourceApi res = new api.DataflowApi(mock).projects.jobs.messages;
       var arg_projectId = "foo";
       var arg_jobId = "foo";
+      var arg_location = "foo";
+      var arg_endTime = "foo";
+      var arg_startTime = "foo";
+      var arg_pageToken = "foo";
       var arg_pageSize = 42;
       var arg_minimumImportance = "foo";
-      var arg_endTime = "foo";
-      var arg_location = "foo";
-      var arg_pageToken = "foo";
-      var arg_startTime = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
         pathOffset += 1;
         unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
         pathOffset += 14;
         index = path.indexOf("/jobs/", pathOffset);
@@ skipping 20 matching lines @@
           if (n == "false") return false;
           if (n == null) return null;
           throw new core.ArgumentError("Invalid boolean: $n");
         }
         if (query.length > 0) {
           for (var part in query.split("&")) {
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
+        unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
+        unittest.expect(queryMap["endTime"].first, unittest.equals(arg_endTime));
+        unittest.expect(queryMap["startTime"].first, unittest.equals(arg_startTime));
+        unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
         unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
         unittest.expect(queryMap["minimumImportance"].first, unittest.equals(arg_minimumImportance));
-        unittest.expect(queryMap["endTime"].first, unittest.equals(arg_endTime));
-        unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
-        unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
-        unittest.expect(queryMap["startTime"].first, unittest.equals(arg_startTime));
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildListJobMessagesResponse());
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
-      res.list(arg_projectId, arg_jobId, pageSize: arg_pageSize, minimumImportance: arg_minimumImportance, endTime: arg_endTime, location: arg_location, pageToken: arg_pageToken, startTime: arg_startTime).then(unittest.expectAsync(((api.ListJobMessagesResponse response) {
+      res.list(arg_projectId, arg_jobId, location: arg_location, endTime: arg_endTime, startTime: arg_startTime, pageToken: arg_pageToken, pageSize: arg_pageSize, minimumImportance: arg_minimumImportance).then(unittest.expectAsync(((api.ListJobMessagesResponse response) {
         checkListJobMessagesResponse(response);
       })));
     });
 
   });
 
 
   unittest.group("resource-ProjectsJobsWorkItemsResourceApi", () {
     unittest.test("method--lease", () {
 
@@ skipping 117 matching lines @@
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.reportStatus(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.ReportWorkItemStatusResponse response) {
         checkReportWorkItemStatusResponse(response);
       })));
     });
 
   });
 
 
+  unittest.group("resource-ProjectsLocationsResourceApi", () {
+    unittest.test("method--workerMessages", () {
+
+      var mock = new HttpServerMock();
+      api.ProjectsLocationsResourceApi res = new api.DataflowApi(mock).projects.locations;
+      var arg_request = buildSendWorkerMessagesRequest();
+      var arg_projectId = "foo";
+      var arg_location = "foo";
+      mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+        var obj = new api.SendWorkerMessagesRequest.fromJson(json);
+        checkSendWorkerMessagesRequest(obj);
+
+        var path = (req.url).path;
+        var pathOffset = 0;
+        var index;
+        var subPart;
+        unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
+        pathOffset += 1;
+        unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
+        pathOffset += 14;
+        index = path.indexOf("/locations/", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_projectId"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 11), unittest.equals("/locations/"));
+        pathOffset += 11;
+        index = path.indexOf("/WorkerMessages", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_location"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.equals("/WorkerMessages"));
+        pathOffset += 15;
+
+        var query = (req.url).query;
+        var queryOffset = 0;
+        var queryMap = {};
+        addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
+        parseBool(n) {
+          if (n == "true") return true;
+          if (n == "false") return false;
+          if (n == null) return null;
+          throw new core.ArgumentError("Invalid boolean: $n");
+        }
+        if (query.length > 0) {
+          for (var part in query.split("&")) {
+            var keyvalue = part.split("=");
+            addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
+          }
+        }
+
+
+        var h = {
+          "content-type" : "application/json; charset=utf-8",
+        };
+        var resp = convert.JSON.encode(buildSendWorkerMessagesResponse());
+        return new async.Future.value(stringResponse(200, h, resp));
+      }), true);
+      res.workerMessages(arg_request, arg_projectId, arg_location).then(unittest.expectAsync(((api.SendWorkerMessagesResponse response) {
+        checkSendWorkerMessagesResponse(response);
+      })));
+    });
+
+  });
+
+
   unittest.group("resource-ProjectsLocationsJobsResourceApi", () {
     unittest.test("method--create", () {
 
       var mock = new HttpServerMock();
       api.ProjectsLocationsJobsResourceApi res = new api.DataflowApi(mock).projects.locations.jobs;
       var arg_request = buildJob();
       var arg_projectId = "foo";
       var arg_location = "foo";
       var arg_view = "foo";
       var arg_replaceJobId = "foo";
@@ skipping 188 matching lines @@
         checkJobMetrics(response);
       })));
     });
 
     unittest.test("method--list", () {
 
       var mock = new HttpServerMock();
       api.ProjectsLocationsJobsResourceApi res = new api.DataflowApi(mock).projects.locations.jobs;
       var arg_projectId = "foo";
       var arg_location = "foo";
+      var arg_filter = "foo";
+      var arg_pageToken = "foo";
       var arg_pageSize = 42;
       var arg_view = "foo";
-      var arg_filter = "foo";
-      var arg_pageToken = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
         pathOffset += 1;
         unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
         pathOffset += 14;
         index = path.indexOf("/locations/", pathOffset);
@@ skipping 20 matching lines @@
           if (n == "false") return false;
           if (n == null) return null;
           throw new core.ArgumentError("Invalid boolean: $n");
         }
         if (query.length > 0) {
           for (var part in query.split("&")) {
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
+        unittest.expect(queryMap["filter"].first, unittest.equals(arg_filter));
+        unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
         unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
         unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
-        unittest.expect(queryMap["filter"].first, unittest.equals(arg_filter));
-        unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildListJobsResponse());
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
-      res.list(arg_projectId, arg_location, pageSize: arg_pageSize, view: arg_view, filter: arg_filter, pageToken: arg_pageToken).then(unittest.expectAsync(((api.ListJobsResponse response) {
+      res.list(arg_projectId, arg_location, filter: arg_filter, pageToken: arg_pageToken, pageSize: arg_pageSize, view: arg_view).then(unittest.expectAsync(((api.ListJobsResponse response) {
         checkListJobsResponse(response);
       })));
     });
 
     unittest.test("method--update", () {
 
       var mock = new HttpServerMock();
       api.ProjectsLocationsJobsResourceApi res = new api.DataflowApi(mock).projects.locations.jobs;
       var arg_request = buildJob();
       var arg_projectId = "foo";
@@ skipping 54 matching lines @@
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.update(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync(((api.Job response) {
         checkJob(response);
       })));
     });
 
   });
 
 
+  unittest.group("resource-ProjectsLocationsJobsDebugResourceApi", () {
+    unittest.test("method--getConfig", () {
+
+      var mock = new HttpServerMock();
+      api.ProjectsLocationsJobsDebugResourceApi res = new api.DataflowApi(mock).projects.locations.jobs.debug;
+      var arg_request = buildGetDebugConfigRequest();
+      var arg_projectId = "foo";
+      var arg_location = "foo";
+      var arg_jobId = "foo";
+      mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+        var obj = new api.GetDebugConfigRequest.fromJson(json);
+        checkGetDebugConfigRequest(obj);
+
+        var path = (req.url).path;
+        var pathOffset = 0;
+        var index;
+        var subPart;
+        unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
+        pathOffset += 1;
+        unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
+        pathOffset += 14;
+        index = path.indexOf("/locations/", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_projectId"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 11), unittest.equals("/locations/"));
+        pathOffset += 11;
+        index = path.indexOf("/jobs/", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_location"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equals("/jobs/"));
+        pathOffset += 6;
+        index = path.indexOf("/debug/getConfig", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_jobId"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 16), unittest.equals("/debug/getConfig"));
+        pathOffset += 16;
+
+        var query = (req.url).query;
+        var queryOffset = 0;
+        var queryMap = {};
+        addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
+        parseBool(n) {
+          if (n == "true") return true;
+          if (n == "false") return false;
+          if (n == null) return null;
+          throw new core.ArgumentError("Invalid boolean: $n");
+        }
+        if (query.length > 0) {
+          for (var part in query.split("&")) {
+            var keyvalue = part.split("=");
+            addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
+          }
+        }
+
+
+        var h = {
+          "content-type" : "application/json; charset=utf-8",
+        };
+        var resp = convert.JSON.encode(buildGetDebugConfigResponse());
+        return new async.Future.value(stringResponse(200, h, resp));
+      }), true);
+      res.getConfig(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync(((api.GetDebugConfigResponse response) {
+        checkGetDebugConfigResponse(response);
+      })));
+    });
+
+    unittest.test("method--sendCapture", () {
+
+      var mock = new HttpServerMock();
+      api.ProjectsLocationsJobsDebugResourceApi res = new api.DataflowApi(mock).projects.locations.jobs.debug;
+      var arg_request = buildSendDebugCaptureRequest();
+      var arg_projectId = "foo";
+      var arg_location = "foo";
+      var arg_jobId = "foo";
+      mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+        var obj = new api.SendDebugCaptureRequest.fromJson(json);
+        checkSendDebugCaptureRequest(obj);
+
+        var path = (req.url).path;
+        var pathOffset = 0;
+        var index;
+        var subPart;
+        unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
+        pathOffset += 1;
+        unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
+        pathOffset += 14;
+        index = path.indexOf("/locations/", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_projectId"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 11), unittest.equals("/locations/"));
+        pathOffset += 11;
+        index = path.indexOf("/jobs/", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_location"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 6), unittest.equals("/jobs/"));
+        pathOffset += 6;
+        index = path.indexOf("/debug/sendCapture", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_jobId"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 18), unittest.equals("/debug/sendCapture"));
+        pathOffset += 18;
+
+        var query = (req.url).query;
+        var queryOffset = 0;
+        var queryMap = {};
+        addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
+        parseBool(n) {
+          if (n == "true") return true;
+          if (n == "false") return false;
+          if (n == null) return null;
+          throw new core.ArgumentError("Invalid boolean: $n");
+        }
+        if (query.length > 0) {
+          for (var part in query.split("&")) {
+            var keyvalue = part.split("=");
+            addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
+          }
+        }
+
+
+        var h = {
+          "content-type" : "application/json; charset=utf-8",
+        };
+        var resp = convert.JSON.encode(buildSendDebugCaptureResponse());
+        return new async.Future.value(stringResponse(200, h, resp));
+      }), true);
+      res.sendCapture(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync(((api.SendDebugCaptureResponse response) {
+        checkSendDebugCaptureResponse(response);
+      })));
+    });
+
+  });
+
+
   unittest.group("resource-ProjectsLocationsJobsMessagesResourceApi", () {
     unittest.test("method--list", () {
 
       var mock = new HttpServerMock();
       api.ProjectsLocationsJobsMessagesResourceApi res = new api.DataflowApi(mock).projects.locations.jobs.messages;
       var arg_projectId = "foo";
       var arg_location = "foo";
       var arg_jobId = "foo";
       var arg_endTime = "foo";
       var arg_pageToken = "foo";
@@ skipping 207 matching lines @@
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.reportStatus(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync(((api.ReportWorkItemStatusResponse response) {
         checkReportWorkItemStatusResponse(response);
       })));
     });
 
   });
 
 
+  unittest.group("resource-ProjectsLocationsTemplatesResourceApi", () {
+    unittest.test("method--create", () {
+
+      var mock = new HttpServerMock();
+      api.ProjectsLocationsTemplatesResourceApi res = new api.DataflowApi(mock).projects.locations.templates;
+      var arg_request = buildCreateJobFromTemplateRequest();
+      var arg_projectId = "foo";
+      var arg_location = "foo";
+      mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+        var obj = new api.CreateJobFromTemplateRequest.fromJson(json);
+        checkCreateJobFromTemplateRequest(obj);
+
+        var path = (req.url).path;
+        var pathOffset = 0;
+        var index;
+        var subPart;
+        unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
+        pathOffset += 1;
+        unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
+        pathOffset += 14;
+        index = path.indexOf("/locations/", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_projectId"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 11), unittest.equals("/locations/"));
+        pathOffset += 11;
+        index = path.indexOf("/templates", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_location"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 10), unittest.equals("/templates"));
+        pathOffset += 10;
+
+        var query = (req.url).query;
+        var queryOffset = 0;
+        var queryMap = {};
+        addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
+        parseBool(n) {
+          if (n == "true") return true;
+          if (n == "false") return false;
+          if (n == null) return null;
+          throw new core.ArgumentError("Invalid boolean: $n");
+        }
+        if (query.length > 0) {
+          for (var part in query.split("&")) {
+            var keyvalue = part.split("=");
+            addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
+          }
+        }
+
+
+        var h = {
+          "content-type" : "application/json; charset=utf-8",
+        };
+        var resp = convert.JSON.encode(buildJob());
+        return new async.Future.value(stringResponse(200, h, resp));
+      }), true);
+      res.create(arg_request, arg_projectId, arg_location).then(unittest.expectAsync(((api.Job response) {
+        checkJob(response);
+      })));
+    });
+
+    unittest.test("method--get", () {
+
+      var mock = new HttpServerMock();
+      api.ProjectsLocationsTemplatesResourceApi res = new api.DataflowApi(mock).projects.locations.templates;
+      var arg_projectId = "foo";
+      var arg_location = "foo";
+      var arg_view = "foo";
+      var arg_gcsPath = "foo";
+      mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+        var path = (req.url).path;
+        var pathOffset = 0;
+        var index;
+        var subPart;
+        unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
+        pathOffset += 1;
+        unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
+        pathOffset += 14;
+        index = path.indexOf("/locations/", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_projectId"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 11), unittest.equals("/locations/"));
+        pathOffset += 11;
+        index = path.indexOf("/templates:get", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_location"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("/templates:get"));
+        pathOffset += 14;
+
+        var query = (req.url).query;
+        var queryOffset = 0;
+        var queryMap = {};
+        addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
+        parseBool(n) {
+          if (n == "true") return true;
+          if (n == "false") return false;
+          if (n == null) return null;
+          throw new core.ArgumentError("Invalid boolean: $n");
+        }
+        if (query.length > 0) {
+          for (var part in query.split("&")) {
+            var keyvalue = part.split("=");
+            addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
+          }
+        }
+        unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
+        unittest.expect(queryMap["gcsPath"].first, unittest.equals(arg_gcsPath));
+
+
+        var h = {
+          "content-type" : "application/json; charset=utf-8",
+        };
+        var resp = convert.JSON.encode(buildGetTemplateResponse());
+        return new async.Future.value(stringResponse(200, h, resp));
+      }), true);
+      res.get(arg_projectId, arg_location, view: arg_view, gcsPath: arg_gcsPath).then(unittest.expectAsync(((api.GetTemplateResponse response) {
+        checkGetTemplateResponse(response);
+      })));
+    });
+
+    unittest.test("method--launch", () {
+
+      var mock = new HttpServerMock();
+      api.ProjectsLocationsTemplatesResourceApi res = new api.DataflowApi(mock).projects.locations.templates;
+      var arg_request = buildLaunchTemplateParameters();
+      var arg_projectId = "foo";
+      var arg_location = "foo";
+      var arg_gcsPath = "foo";
+      var arg_dryRun = true;
+      mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+        var obj = new api.LaunchTemplateParameters.fromJson(json);
+        checkLaunchTemplateParameters(obj);
+
+        var path = (req.url).path;
+        var pathOffset = 0;
+        var index;
+        var subPart;
+        unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
+        pathOffset += 1;
+        unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
+        pathOffset += 14;
+        index = path.indexOf("/locations/", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_projectId"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 11), unittest.equals("/locations/"));
+        pathOffset += 11;
+        index = path.indexOf("/templates:launch", pathOffset);
+        unittest.expect(index >= 0, unittest.isTrue);
+        subPart = core.Uri.decodeQueryComponent(path.substring(pathOffset, index));
+        pathOffset = index;
+        unittest.expect(subPart, unittest.equals("$arg_location"));
+        unittest.expect(path.substring(pathOffset, pathOffset + 17), unittest.equals("/templates:launch"));
+        pathOffset += 17;
+
+        var query = (req.url).query;
+        var queryOffset = 0;
+        var queryMap = {};
+        addQueryParam(n, v) => queryMap.putIfAbsent(n, () => []).add(v);
+        parseBool(n) {
+          if (n == "true") return true;
+          if (n == "false") return false;
+          if (n == null) return null;
+          throw new core.ArgumentError("Invalid boolean: $n");
+        }
+        if (query.length > 0) {
+          for (var part in query.split("&")) {
+            var keyvalue = part.split("=");
+            addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
+          }
+        }
+        unittest.expect(queryMap["gcsPath"].first, unittest.equals(arg_gcsPath));
+        unittest.expect(queryMap["dryRun"].first, unittest.equals("$arg_dryRun"));
+
+
+        var h = {
+          "content-type" : "application/json; charset=utf-8",
+        };
+        var resp = convert.JSON.encode(buildLaunchTemplateResponse());
+        return new async.Future.value(stringResponse(200, h, resp));
+      }), true);
+      res.launch(arg_request, arg_projectId, arg_location, gcsPath: arg_gcsPath, dryRun: arg_dryRun).then(unittest.expectAsync(((api.LaunchTemplateResponse response) {
+        checkLaunchTemplateResponse(response);
+      })));
+    });
+
+  });
+
+
   unittest.group("resource-ProjectsTemplatesResourceApi", () {
     unittest.test("method--create", () {
 
       var mock = new HttpServerMock();
       api.ProjectsTemplatesResourceApi res = new api.DataflowApi(mock).projects.templates;
       var arg_request = buildCreateJobFromTemplateRequest();
       var arg_projectId = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.CreateJobFromTemplateRequest.fromJson(json);
         checkCreateJobFromTemplateRequest(obj);
@@ skipping 43 matching lines @@
       })));
     });
 
     unittest.test("method--get", () {
 
       var mock = new HttpServerMock();
       api.ProjectsTemplatesResourceApi res = new api.DataflowApi(mock).projects.templates;
       var arg_projectId = "foo";
       var arg_view = "foo";
       var arg_gcsPath = "foo";
+      var arg_location = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
         pathOffset += 1;
         unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
         pathOffset += 14;
         index = path.indexOf("/templates:get", pathOffset);
@@ skipping 15 matching lines @@
           throw new core.ArgumentError("Invalid boolean: $n");
         }
         if (query.length > 0) {
           for (var part in query.split("&")) {
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
         unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
         unittest.expect(queryMap["gcsPath"].first, unittest.equals(arg_gcsPath));
+        unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildGetTemplateResponse());
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
-      res.get(arg_projectId, view: arg_view, gcsPath: arg_gcsPath).then(unittest.expectAsync(((api.GetTemplateResponse response) {
+      res.get(arg_projectId, view: arg_view, gcsPath: arg_gcsPath, location: arg_location).then(unittest.expectAsync(((api.GetTemplateResponse response) {
         checkGetTemplateResponse(response);
       })));
     });
 
     unittest.test("method--launch", () {
 
       var mock = new HttpServerMock();
       api.ProjectsTemplatesResourceApi res = new api.DataflowApi(mock).projects.templates;
       var arg_request = buildLaunchTemplateParameters();
       var arg_projectId = "foo";
       var arg_gcsPath = "foo";
       var arg_dryRun = true;
+      var arg_location = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.LaunchTemplateParameters.fromJson(json);
         checkLaunchTemplateParameters(obj);
 
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
         pathOffset += 1;
@@ skipping 18 matching lines @@
           throw new core.ArgumentError("Invalid boolean: $n");
         }
         if (query.length > 0) {
           for (var part in query.split("&")) {
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
         unittest.expect(queryMap["gcsPath"].first, unittest.equals(arg_gcsPath));
         unittest.expect(queryMap["dryRun"].first, unittest.equals("$arg_dryRun"));
+        unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildLaunchTemplateResponse());
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
-      res.launch(arg_request, arg_projectId, gcsPath: arg_gcsPath, dryRun: arg_dryRun).then(unittest.expectAsync(((api.LaunchTemplateResponse response) {
+      res.launch(arg_request, arg_projectId, gcsPath: arg_gcsPath, dryRun: arg_dryRun, location: arg_location).then(unittest.expectAsync(((api.LaunchTemplateResponse response) {
         checkLaunchTemplateResponse(response);
       })));
     });
 
   });
 
 
 }