Api-roll 46: 2017-03-06

generated/googleapis_beta/test/dataflow/v1b3_test.dart

Index: generated/googleapis_beta/test/dataflow/v1b3_test.dart
diff --git a/generated/googleapis_beta/test/dataflow/v1b3_test.dart b/generated/googleapis_beta/test/dataflow/v1b3_test.dart
index 20b239b652954119b6642321547149505824a24d..0e8d4931a0c826460fd5c5ab46501d59500e84f9 100644
--- a/generated/googleapis_beta/test/dataflow/v1b3_test.dart
+++ b/generated/googleapis_beta/test/dataflow/v1b3_test.dart
@@ -164,53 +164,99 @@ checkCPUTime(api.CPUTime o) {
   buildCounterCPUTime--;
 }
 
-buildUnnamed3138() {
+core.int buildCounterComponentSource = 0;
+buildComponentSource() {
+  var o = new api.ComponentSource();
+  buildCounterComponentSource++;
+  if (buildCounterComponentSource < 3) {
+    o.name = "foo";
+    o.originalTransformOrCollection = "foo";
+    o.userName = "foo";
+  }
+  buildCounterComponentSource--;
+  return o;
+}
+
+checkComponentSource(api.ComponentSource o) {
+  buildCounterComponentSource++;
+  if (buildCounterComponentSource < 3) {
+    unittest.expect(o.name, unittest.equals('foo'));
+    unittest.expect(o.originalTransformOrCollection, unittest.equals('foo'));
+    unittest.expect(o.userName, unittest.equals('foo'));
+  }
+  buildCounterComponentSource--;
+}
+
+core.int buildCounterComponentTransform = 0;
+buildComponentTransform() {
+  var o = new api.ComponentTransform();
+  buildCounterComponentTransform++;
+  if (buildCounterComponentTransform < 3) {
+    o.name = "foo";
+    o.originalTransform = "foo";
+    o.userName = "foo";
+  }
+  buildCounterComponentTransform--;
+  return o;
+}
+
+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--;
+}
+
+buildUnnamed2973() {
   var o = new core.List<api.StreamLocation>();
   o.add(buildStreamLocation());
   o.add(buildStreamLocation());
   return o;
 }
 
-checkUnnamed3138(core.List<api.StreamLocation> o) {
+checkUnnamed2973(core.List<api.StreamLocation> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStreamLocation(o[0]);
   checkStreamLocation(o[1]);
 }
 
-buildUnnamed3139() {
+buildUnnamed2974() {
   var o = new core.List<api.KeyRangeLocation>();
   o.add(buildKeyRangeLocation());
   o.add(buildKeyRangeLocation());
   return o;
 }
 
-checkUnnamed3139(core.List<api.KeyRangeLocation> o) {
+checkUnnamed2974(core.List<api.KeyRangeLocation> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkKeyRangeLocation(o[0]);
   checkKeyRangeLocation(o[1]);
 }
 
-buildUnnamed3140() {
+buildUnnamed2975() {
   var o = new core.List<api.StreamLocation>();
   o.add(buildStreamLocation());
   o.add(buildStreamLocation());
   return o;
 }
 
-checkUnnamed3140(core.List<api.StreamLocation> o) {
+checkUnnamed2975(core.List<api.StreamLocation> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStreamLocation(o[0]);
   checkStreamLocation(o[1]);
 }
 
-buildUnnamed3141() {
+buildUnnamed2976() {
   var o = new core.List<api.StateFamilyConfig>();
   o.add(buildStateFamilyConfig());
   o.add(buildStateFamilyConfig());
   return o;
 }
 
-checkUnnamed3141(core.List<api.StateFamilyConfig> o) {
+checkUnnamed2976(core.List<api.StateFamilyConfig> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStateFamilyConfig(o[0]);
   checkStateFamilyConfig(o[1]);
@@ -222,10 +268,10 @@ buildComputationTopology() {
   buildCounterComputationTopology++;
   if (buildCounterComputationTopology < 3) {
     o.computationId = "foo";
-    o.inputs = buildUnnamed3138();
-    o.keyRanges = buildUnnamed3139();
-    o.outputs = buildUnnamed3140();
-    o.stateFamilies = buildUnnamed3141();
+    o.inputs = buildUnnamed2973();
+    o.keyRanges = buildUnnamed2974();
+    o.outputs = buildUnnamed2975();
+    o.stateFamilies = buildUnnamed2976();
     o.systemStageName = "foo";
     o.userStageName = "foo";
   }
@@ -237,10 +283,10 @@ checkComputationTopology(api.ComputationTopology o) {
   buildCounterComputationTopology++;
   if (buildCounterComputationTopology < 3) {
     unittest.expect(o.computationId, unittest.equals('foo'));
-    checkUnnamed3138(o.inputs);
-    checkUnnamed3139(o.keyRanges);
-    checkUnnamed3140(o.outputs);
-    checkUnnamed3141(o.stateFamilies);
+    checkUnnamed2973(o.inputs);
+    checkUnnamed2974(o.keyRanges);
+    checkUnnamed2975(o.outputs);
+    checkUnnamed2976(o.stateFamilies);
     unittest.expect(o.systemStageName, unittest.equals('foo'));
     unittest.expect(o.userStageName, unittest.equals('foo'));
   }
@@ -392,14 +438,14 @@ checkCounterUpdate(api.CounterUpdate o) {
   buildCounterCounterUpdate--;
 }
 
-buildUnnamed3142() {
+buildUnnamed2977() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3142(core.Map<core.String, core.String> o) {
+checkUnnamed2977(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'));
@@ -413,7 +459,7 @@ buildCreateJobFromTemplateRequest() {
     o.environment = buildRuntimeEnvironment();
     o.gcsPath = "foo";
     o.jobName = "foo";
-    o.parameters = buildUnnamed3142();
+    o.parameters = buildUnnamed2977();
   }
   buildCounterCreateJobFromTemplateRequest--;
   return o;
@@ -425,7 +471,7 @@ checkCreateJobFromTemplateRequest(api.CreateJobFromTemplateRequest o) {
     checkRuntimeEnvironment(o.environment);
     unittest.expect(o.gcsPath, unittest.equals('foo'));
     unittest.expect(o.jobName, unittest.equals('foo'));
-    checkUnnamed3142(o.parameters);
+    checkUnnamed2977(o.parameters);
   }
   buildCounterCreateJobFromTemplateRequest--;
 }
@@ -449,14 +495,14 @@ checkCustomSourceLocation(api.CustomSourceLocation o) {
   buildCounterCustomSourceLocation--;
 }
 
-buildUnnamed3143() {
+buildUnnamed2978() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3143(core.List<core.String> o) {
+checkUnnamed2978(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'));
@@ -467,7 +513,7 @@ buildDataDiskAssignment() {
   var o = new api.DataDiskAssignment();
   buildCounterDataDiskAssignment++;
   if (buildCounterDataDiskAssignment < 3) {
-    o.dataDisks = buildUnnamed3143();
+    o.dataDisks = buildUnnamed2978();
     o.vmInstance = "foo";
   }
   buildCounterDataDiskAssignment--;
@@ -477,7 +523,7 @@ buildDataDiskAssignment() {
 checkDataDiskAssignment(api.DataDiskAssignment o) {
   buildCounterDataDiskAssignment++;
   if (buildCounterDataDiskAssignment < 3) {
-    checkUnnamed3143(o.dataDisks);
+    checkUnnamed2978(o.dataDisks);
     unittest.expect(o.vmInstance, unittest.equals('foo'));
   }
   buildCounterDataDiskAssignment--;
@@ -527,6 +573,47 @@ checkDisk(api.Disk o) {
   buildCounterDisk--;
 }
 
+core.int buildCounterDisplayData = 0;
+buildDisplayData() {
+  var o = new api.DisplayData();
+  buildCounterDisplayData++;
+  if (buildCounterDisplayData < 3) {
+    o.boolValue = true;
+    o.durationValue = "foo";
+    o.floatValue = 42.0;
+    o.int64Value = "foo";
+    o.javaClassValue = "foo";
+    o.key = "foo";
+    o.label = "foo";
+    o.namespace = "foo";
+    o.shortStrValue = "foo";
+    o.strValue = "foo";
+    o.timestampValue = "foo";
+    o.url = "foo";
+  }
+  buildCounterDisplayData--;
+  return o;
+}
+
+checkDisplayData(api.DisplayData o) {
+  buildCounterDisplayData++;
+  if (buildCounterDisplayData < 3) {
+    unittest.expect(o.boolValue, unittest.isTrue);
+    unittest.expect(o.durationValue, unittest.equals('foo'));
+    unittest.expect(o.floatValue, unittest.equals(42.0));
+    unittest.expect(o.int64Value, unittest.equals('foo'));
+    unittest.expect(o.javaClassValue, unittest.equals('foo'));
+    unittest.expect(o.key, unittest.equals('foo'));
+    unittest.expect(o.label, unittest.equals('foo'));
+    unittest.expect(o.namespace, unittest.equals('foo'));
+    unittest.expect(o.shortStrValue, unittest.equals('foo'));
+    unittest.expect(o.strValue, unittest.equals('foo'));
+    unittest.expect(o.timestampValue, unittest.equals('foo'));
+    unittest.expect(o.url, unittest.equals('foo'));
+  }
+  buildCounterDisplayData--;
+}
+
 core.int buildCounterDistributionUpdate = 0;
 buildDistributionUpdate() {
   var o = new api.DistributionUpdate();
@@ -575,79 +662,79 @@ checkDynamicSourceSplit(api.DynamicSourceSplit o) {
   buildCounterDynamicSourceSplit--;
 }
 
-buildUnnamed3144() {
+buildUnnamed2979() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3144(core.List<core.String> o) {
+checkUnnamed2979(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'));
 }
 
-buildUnnamed3145() {
+buildUnnamed2980() {
   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) {
+checkUnnamed2980(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')); 
 }
 
-buildUnnamed3146() {
+buildUnnamed2981() {
   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;
 }
 
-checkUnnamed3146(core.Map<core.String, core.Object> o) {
+checkUnnamed2981(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')); 
 }
 
-buildUnnamed3147() {
+buildUnnamed2982() {
   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;
 }
 
-checkUnnamed3147(core.Map<core.String, core.Object> o) {
+checkUnnamed2982(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')); 
 }
 
-buildUnnamed3148() {
+buildUnnamed2983() {
   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) {
+checkUnnamed2983(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')); 
 }
 
-buildUnnamed3149() {
+buildUnnamed2984() {
   var o = new core.List<api.WorkerPool>();
   o.add(buildWorkerPool());
   o.add(buildWorkerPool());
   return o;
 }
 
-checkUnnamed3149(core.List<api.WorkerPool> o) {
+checkUnnamed2984(core.List<api.WorkerPool> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkerPool(o[0]);
   checkWorkerPool(o[1]);
@@ -660,14 +747,14 @@ buildEnvironment() {
   if (buildCounterEnvironment < 3) {
     o.clusterManagerApiService = "foo";
     o.dataset = "foo";
-    o.experiments = buildUnnamed3144();
-    o.internalExperiments = buildUnnamed3145();
-    o.sdkPipelineOptions = buildUnnamed3146();
+    o.experiments = buildUnnamed2979();
+    o.internalExperiments = buildUnnamed2980();
+    o.sdkPipelineOptions = buildUnnamed2981();
     o.serviceAccountEmail = "foo";
     o.tempStoragePrefix = "foo";
-    o.userAgent = buildUnnamed3147();
-    o.version = buildUnnamed3148();
-    o.workerPools = buildUnnamed3149();
+    o.userAgent = buildUnnamed2982();
+    o.version = buildUnnamed2983();
+    o.workerPools = buildUnnamed2984();
   }
   buildCounterEnvironment--;
   return o;
@@ -678,18 +765,101 @@ checkEnvironment(api.Environment o) {
   if (buildCounterEnvironment < 3) {
     unittest.expect(o.clusterManagerApiService, unittest.equals('foo'));
     unittest.expect(o.dataset, unittest.equals('foo'));
-    checkUnnamed3144(o.experiments);
-    checkUnnamed3145(o.internalExperiments);
-    checkUnnamed3146(o.sdkPipelineOptions);
+    checkUnnamed2979(o.experiments);
+    checkUnnamed2980(o.internalExperiments);
+    checkUnnamed2981(o.sdkPipelineOptions);
     unittest.expect(o.serviceAccountEmail, unittest.equals('foo'));
     unittest.expect(o.tempStoragePrefix, unittest.equals('foo'));
-    checkUnnamed3147(o.userAgent);
-    checkUnnamed3148(o.version);
-    checkUnnamed3149(o.workerPools);
+    checkUnnamed2982(o.userAgent);
+    checkUnnamed2983(o.version);
+    checkUnnamed2984(o.workerPools);
   }
   buildCounterEnvironment--;
 }
 
+buildUnnamed2985() {
+  var o = new core.List<api.ComponentSource>();
+  o.add(buildComponentSource());
+  o.add(buildComponentSource());
+  return o;
+}
+
+checkUnnamed2985(core.List<api.ComponentSource> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  checkComponentSource(o[0]);
+  checkComponentSource(o[1]);
+}
+
+buildUnnamed2986() {
+  var o = new core.List<api.ComponentTransform>();
+  o.add(buildComponentTransform());
+  o.add(buildComponentTransform());
+  return o;
+}
+
+checkUnnamed2986(core.List<api.ComponentTransform> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  checkComponentTransform(o[0]);
+  checkComponentTransform(o[1]);
+}
+
+buildUnnamed2987() {
+  var o = new core.List<api.StageSource>();
+  o.add(buildStageSource());
+  o.add(buildStageSource());
+  return o;
+}
+
+checkUnnamed2987(core.List<api.StageSource> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  checkStageSource(o[0]);
+  checkStageSource(o[1]);
+}
+
+buildUnnamed2988() {
+  var o = new core.List<api.StageSource>();
+  o.add(buildStageSource());
+  o.add(buildStageSource());
+  return o;
+}
+
+checkUnnamed2988(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 = buildUnnamed2985();
+    o.componentTransform = buildUnnamed2986();
+    o.id = "foo";
+    o.inputSource = buildUnnamed2987();
+    o.kind = "foo";
+    o.name = "foo";
+    o.outputSource = buildUnnamed2988();
+  }
+  buildCounterExecutionStageSummary--;
+  return o;
+}
+
+checkExecutionStageSummary(api.ExecutionStageSummary o) {
+  buildCounterExecutionStageSummary++;
+  if (buildCounterExecutionStageSummary < 3) {
+    checkUnnamed2985(o.componentSource);
+    checkUnnamed2986(o.componentTransform);
+    unittest.expect(o.id, unittest.equals('foo'));
+    checkUnnamed2987(o.inputSource);
+    unittest.expect(o.kind, unittest.equals('foo'));
+    unittest.expect(o.name, unittest.equals('foo'));
+    checkUnnamed2988(o.outputSource);
+  }
+  buildCounterExecutionStageSummary--;
+}
+
 core.int buildCounterFailedLocation = 0;
 buildFailedLocation() {
   var o = new api.FailedLocation();
@@ -709,14 +879,14 @@ checkFailedLocation(api.FailedLocation o) {
   buildCounterFailedLocation--;
 }
 
-buildUnnamed3150() {
+buildUnnamed2989() {
   var o = new core.List<api.InstructionInput>();
   o.add(buildInstructionInput());
   o.add(buildInstructionInput());
   return o;
 }
 
-checkUnnamed3150(core.List<api.InstructionInput> o) {
+checkUnnamed2989(core.List<api.InstructionInput> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkInstructionInput(o[0]);
   checkInstructionInput(o[1]);
@@ -727,7 +897,7 @@ buildFlattenInstruction() {
   var o = new api.FlattenInstruction();
   buildCounterFlattenInstruction++;
   if (buildCounterFlattenInstruction < 3) {
-    o.inputs = buildUnnamed3150();
+    o.inputs = buildUnnamed2989();
   }
   buildCounterFlattenInstruction--;
   return o;
@@ -736,19 +906,19 @@ buildFlattenInstruction() {
 checkFlattenInstruction(api.FlattenInstruction o) {
   buildCounterFlattenInstruction++;
   if (buildCounterFlattenInstruction < 3) {
-    checkUnnamed3150(o.inputs);
+    checkUnnamed2989(o.inputs);
   }
   buildCounterFlattenInstruction--;
 }
 
-buildUnnamed3151() {
+buildUnnamed2990() {
   var o = new core.List<core.double>();
   o.add(42.0);
   o.add(42.0);
   return o;
 }
 
-checkUnnamed3151(core.List<core.double> o) {
+checkUnnamed2990(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));
@@ -759,7 +929,7 @@ buildFloatingPointList() {
   var o = new api.FloatingPointList();
   buildCounterFloatingPointList++;
   if (buildCounterFloatingPointList < 3) {
-    o.elements = buildUnnamed3151();
+    o.elements = buildUnnamed2990();
   }
   buildCounterFloatingPointList--;
   return o;
@@ -768,7 +938,7 @@ buildFloatingPointList() {
 checkFloatingPointList(api.FloatingPointList o) {
   buildCounterFloatingPointList++;
   if (buildCounterFloatingPointList < 3) {
-    checkUnnamed3151(o.elements);
+    checkUnnamed2990(o.elements);
   }
   buildCounterFloatingPointList--;
 }
@@ -834,6 +1004,27 @@ checkGetDebugConfigResponse(api.GetDebugConfigResponse o) {
   buildCounterGetDebugConfigResponse--;
 }
 
+core.int buildCounterGetTemplateResponse = 0;
+buildGetTemplateResponse() {
+  var o = new api.GetTemplateResponse();
+  buildCounterGetTemplateResponse++;
+  if (buildCounterGetTemplateResponse < 3) {
+    o.metadata = buildTemplateMetadata();
+    o.status = buildStatus();
+  }
+  buildCounterGetTemplateResponse--;
+  return o;
+}
+
+checkGetTemplateResponse(api.GetTemplateResponse o) {
+  buildCounterGetTemplateResponse++;
+  if (buildCounterGetTemplateResponse < 3) {
+    checkTemplateMetadata(o.metadata);
+    checkStatus(o.status);
+  }
+  buildCounterGetTemplateResponse--;
+}
+
 core.int buildCounterInstructionInput = 0;
 buildInstructionInput() {
   var o = new api.InstructionInput();
@@ -855,14 +1046,14 @@ checkInstructionInput(api.InstructionInput o) {
   buildCounterInstructionInput--;
 }
 
-buildUnnamed3152() {
+buildUnnamed2991() {
   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;
 }
 
-checkUnnamed3152(core.Map<core.String, core.Object> o) {
+checkUnnamed2991(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')); 
@@ -873,7 +1064,7 @@ buildInstructionOutput() {
   var o = new api.InstructionOutput();
   buildCounterInstructionOutput++;
   if (buildCounterInstructionOutput < 3) {
-    o.codec = buildUnnamed3152();
+    o.codec = buildUnnamed2991();
     o.name = "foo";
     o.onlyCountKeyBytes = true;
     o.onlyCountValueBytes = true;
@@ -887,7 +1078,7 @@ buildInstructionOutput() {
 checkInstructionOutput(api.InstructionOutput o) {
   buildCounterInstructionOutput++;
   if (buildCounterInstructionOutput < 3) {
-    checkUnnamed3152(o.codec);
+    checkUnnamed2991(o.codec);
     unittest.expect(o.name, unittest.equals('foo'));
     unittest.expect(o.onlyCountKeyBytes, unittest.isTrue);
     unittest.expect(o.onlyCountValueBytes, unittest.isTrue);
@@ -897,14 +1088,14 @@ checkInstructionOutput(api.InstructionOutput o) {
   buildCounterInstructionOutput--;
 }
 
-buildUnnamed3153() {
+buildUnnamed2992() {
   var o = new core.List<api.SplitInt64>();
   o.add(buildSplitInt64());
   o.add(buildSplitInt64());
   return o;
 }
 
-checkUnnamed3153(core.List<api.SplitInt64> o) {
+checkUnnamed2992(core.List<api.SplitInt64> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSplitInt64(o[0]);
   checkSplitInt64(o[1]);
@@ -915,7 +1106,7 @@ buildIntegerList() {
   var o = new api.IntegerList();
   buildCounterIntegerList++;
   if (buildCounterIntegerList < 3) {
-    o.elements = buildUnnamed3153();
+    o.elements = buildUnnamed2992();
   }
   buildCounterIntegerList--;
   return o;
@@ -924,7 +1115,7 @@ buildIntegerList() {
 checkIntegerList(api.IntegerList o) {
   buildCounterIntegerList++;
   if (buildCounterIntegerList < 3) {
-    checkUnnamed3153(o.elements);
+    checkUnnamed2992(o.elements);
   }
   buildCounterIntegerList--;
 }
@@ -950,53 +1141,53 @@ checkIntegerMean(api.IntegerMean o) {
   buildCounterIntegerMean--;
 }
 
-buildUnnamed3154() {
+buildUnnamed2993() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3154(core.Map<core.String, core.String> o) {
+checkUnnamed2993(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'));
 }
 
-buildUnnamed3155() {
+buildUnnamed2994() {
   var o = new core.List<api.Step>();
   o.add(buildStep());
   o.add(buildStep());
   return o;
 }
 
-checkUnnamed3155(core.List<api.Step> o) {
+checkUnnamed2994(core.List<api.Step> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStep(o[0]);
   checkStep(o[1]);
 }
 
-buildUnnamed3156() {
+buildUnnamed2995() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3156(core.List<core.String> o) {
+checkUnnamed2995(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'));
 }
 
-buildUnnamed3157() {
+buildUnnamed2996() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3157(core.Map<core.String, core.String> o) {
+checkUnnamed2996(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'));
@@ -1014,16 +1205,17 @@ buildJob() {
     o.environment = buildEnvironment();
     o.executionInfo = buildJobExecutionInfo();
     o.id = "foo";
-    o.labels = buildUnnamed3154();
+    o.labels = buildUnnamed2993();
     o.location = "foo";
     o.name = "foo";
+    o.pipelineDescription = buildPipelineDescription();
     o.projectId = "foo";
     o.replaceJobId = "foo";
     o.replacedByJobId = "foo";
     o.requestedState = "foo";
-    o.steps = buildUnnamed3155();
-    o.tempFiles = buildUnnamed3156();
-    o.transformNameMapping = buildUnnamed3157();
+    o.steps = buildUnnamed2994();
+    o.tempFiles = buildUnnamed2995();
+    o.transformNameMapping = buildUnnamed2996();
     o.type = "foo";
   }
   buildCounterJob--;
@@ -1040,29 +1232,30 @@ checkJob(api.Job o) {
     checkEnvironment(o.environment);
     checkJobExecutionInfo(o.executionInfo);
     unittest.expect(o.id, unittest.equals('foo'));
-    checkUnnamed3154(o.labels);
+    checkUnnamed2993(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'));
-    checkUnnamed3155(o.steps);
-    checkUnnamed3156(o.tempFiles);
-    checkUnnamed3157(o.transformNameMapping);
+    checkUnnamed2994(o.steps);
+    checkUnnamed2995(o.tempFiles);
+    checkUnnamed2996(o.transformNameMapping);
     unittest.expect(o.type, unittest.equals('foo'));
   }
   buildCounterJob--;
 }
 
-buildUnnamed3158() {
+buildUnnamed2997() {
   var o = new core.Map<core.String, api.JobExecutionStageInfo>();
   o["x"] = buildJobExecutionStageInfo();
   o["y"] = buildJobExecutionStageInfo();
   return o;
 }
 
-checkUnnamed3158(core.Map<core.String, api.JobExecutionStageInfo> o) {
+checkUnnamed2997(core.Map<core.String, api.JobExecutionStageInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkJobExecutionStageInfo(o["x"]);
   checkJobExecutionStageInfo(o["y"]);
@@ -1073,7 +1266,7 @@ buildJobExecutionInfo() {
   var o = new api.JobExecutionInfo();
   buildCounterJobExecutionInfo++;
   if (buildCounterJobExecutionInfo < 3) {
-    o.stages = buildUnnamed3158();
+    o.stages = buildUnnamed2997();
   }
   buildCounterJobExecutionInfo--;
   return o;
@@ -1082,19 +1275,19 @@ buildJobExecutionInfo() {
 checkJobExecutionInfo(api.JobExecutionInfo o) {
   buildCounterJobExecutionInfo++;
   if (buildCounterJobExecutionInfo < 3) {
-    checkUnnamed3158(o.stages);
+    checkUnnamed2997(o.stages);
   }
   buildCounterJobExecutionInfo--;
 }
 
-buildUnnamed3159() {
+buildUnnamed2998() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3159(core.List<core.String> o) {
+checkUnnamed2998(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'));
@@ -1105,7 +1298,7 @@ buildJobExecutionStageInfo() {
   var o = new api.JobExecutionStageInfo();
   buildCounterJobExecutionStageInfo++;
   if (buildCounterJobExecutionStageInfo < 3) {
-    o.stepName = buildUnnamed3159();
+    o.stepName = buildUnnamed2998();
   }
   buildCounterJobExecutionStageInfo--;
   return o;
@@ -1114,7 +1307,7 @@ buildJobExecutionStageInfo() {
 checkJobExecutionStageInfo(api.JobExecutionStageInfo o) {
   buildCounterJobExecutionStageInfo++;
   if (buildCounterJobExecutionStageInfo < 3) {
-    checkUnnamed3159(o.stepName);
+    checkUnnamed2998(o.stepName);
   }
   buildCounterJobExecutionStageInfo--;
 }
@@ -1144,14 +1337,14 @@ checkJobMessage(api.JobMessage o) {
   buildCounterJobMessage--;
 }
 
-buildUnnamed3160() {
+buildUnnamed2999() {
   var o = new core.List<api.MetricUpdate>();
   o.add(buildMetricUpdate());
   o.add(buildMetricUpdate());
   return o;
 }
 
-checkUnnamed3160(core.List<api.MetricUpdate> o) {
+checkUnnamed2999(core.List<api.MetricUpdate> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkMetricUpdate(o[0]);
   checkMetricUpdate(o[1]);
@@ -1163,7 +1356,7 @@ buildJobMetrics() {
   buildCounterJobMetrics++;
   if (buildCounterJobMetrics < 3) {
     o.metricTime = "foo";
-    o.metrics = buildUnnamed3160();
+    o.metrics = buildUnnamed2999();
   }
   buildCounterJobMetrics--;
   return o;
@@ -1173,7 +1366,7 @@ checkJobMetrics(api.JobMetrics o) {
   buildCounterJobMetrics++;
   if (buildCounterJobMetrics < 3) {
     unittest.expect(o.metricTime, unittest.equals('foo'));
-    checkUnnamed3160(o.metrics);
+    checkUnnamed2999(o.metrics);
   }
   buildCounterJobMetrics--;
 }
@@ -1228,27 +1421,84 @@ checkKeyRangeLocation(api.KeyRangeLocation o) {
   buildCounterKeyRangeLocation--;
 }
 
-buildUnnamed3161() {
+buildUnnamed3000() {
+  var o = new core.Map<core.String, core.String>();
+  o["x"] = "foo";
+  o["y"] = "foo";
+  return o;
+}
+
+checkUnnamed3000(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 = buildUnnamed3000();
+  }
+  buildCounterLaunchTemplateParameters--;
+  return o;
+}
+
+checkLaunchTemplateParameters(api.LaunchTemplateParameters o) {
+  buildCounterLaunchTemplateParameters++;
+  if (buildCounterLaunchTemplateParameters < 3) {
+    checkRuntimeEnvironment(o.environment);
+    unittest.expect(o.jobName, unittest.equals('foo'));
+    checkUnnamed3000(o.parameters);
+  }
+  buildCounterLaunchTemplateParameters--;
+}
+
+core.int buildCounterLaunchTemplateResponse = 0;
+buildLaunchTemplateResponse() {
+  var o = new api.LaunchTemplateResponse();
+  buildCounterLaunchTemplateResponse++;
+  if (buildCounterLaunchTemplateResponse < 3) {
+    o.job = buildJob();
+    o.status = buildStatus();
+  }
+  buildCounterLaunchTemplateResponse--;
+  return o;
+}
+
+checkLaunchTemplateResponse(api.LaunchTemplateResponse o) {
+  buildCounterLaunchTemplateResponse++;
+  if (buildCounterLaunchTemplateResponse < 3) {
+    checkJob(o.job);
+    checkStatus(o.status);
+  }
+  buildCounterLaunchTemplateResponse--;
+}
+
+buildUnnamed3001() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3161(core.List<core.String> o) {
+checkUnnamed3001(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'));
 }
 
-buildUnnamed3162() {
+buildUnnamed3002() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3162(core.List<core.String> o) {
+checkUnnamed3002(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'));
@@ -1262,8 +1512,8 @@ buildLeaseWorkItemRequest() {
     o.currentWorkerTime = "foo";
     o.location = "foo";
     o.requestedLeaseDuration = "foo";
-    o.workItemTypes = buildUnnamed3161();
-    o.workerCapabilities = buildUnnamed3162();
+    o.workItemTypes = buildUnnamed3001();
+    o.workerCapabilities = buildUnnamed3002();
     o.workerId = "foo";
   }
   buildCounterLeaseWorkItemRequest--;
@@ -1276,21 +1526,21 @@ checkLeaseWorkItemRequest(api.LeaseWorkItemRequest o) {
     unittest.expect(o.currentWorkerTime, unittest.equals('foo'));
     unittest.expect(o.location, unittest.equals('foo'));
     unittest.expect(o.requestedLeaseDuration, unittest.equals('foo'));
-    checkUnnamed3161(o.workItemTypes);
-    checkUnnamed3162(o.workerCapabilities);
+    checkUnnamed3001(o.workItemTypes);
+    checkUnnamed3002(o.workerCapabilities);
     unittest.expect(o.workerId, unittest.equals('foo'));
   }
   buildCounterLeaseWorkItemRequest--;
 }
 
-buildUnnamed3163() {
+buildUnnamed3003() {
   var o = new core.List<api.WorkItem>();
   o.add(buildWorkItem());
   o.add(buildWorkItem());
   return o;
 }
 
-checkUnnamed3163(core.List<api.WorkItem> o) {
+checkUnnamed3003(core.List<api.WorkItem> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkItem(o[0]);
   checkWorkItem(o[1]);
@@ -1301,7 +1551,7 @@ buildLeaseWorkItemResponse() {
   var o = new api.LeaseWorkItemResponse();
   buildCounterLeaseWorkItemResponse++;
   if (buildCounterLeaseWorkItemResponse < 3) {
-    o.workItems = buildUnnamed3163();
+    o.workItems = buildUnnamed3003();
   }
   buildCounterLeaseWorkItemResponse--;
   return o;
@@ -1310,19 +1560,19 @@ buildLeaseWorkItemResponse() {
 checkLeaseWorkItemResponse(api.LeaseWorkItemResponse o) {
   buildCounterLeaseWorkItemResponse++;
   if (buildCounterLeaseWorkItemResponse < 3) {
-    checkUnnamed3163(o.workItems);
+    checkUnnamed3003(o.workItems);
   }
   buildCounterLeaseWorkItemResponse--;
 }
 
-buildUnnamed3164() {
+buildUnnamed3004() {
   var o = new core.List<api.JobMessage>();
   o.add(buildJobMessage());
   o.add(buildJobMessage());
   return o;
 }
 
-checkUnnamed3164(core.List<api.JobMessage> o) {
+checkUnnamed3004(core.List<api.JobMessage> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkJobMessage(o[0]);
   checkJobMessage(o[1]);
@@ -1333,7 +1583,7 @@ buildListJobMessagesResponse() {
   var o = new api.ListJobMessagesResponse();
   buildCounterListJobMessagesResponse++;
   if (buildCounterListJobMessagesResponse < 3) {
-    o.jobMessages = buildUnnamed3164();
+    o.jobMessages = buildUnnamed3004();
     o.nextPageToken = "foo";
   }
   buildCounterListJobMessagesResponse--;
@@ -1343,33 +1593,33 @@ buildListJobMessagesResponse() {
 checkListJobMessagesResponse(api.ListJobMessagesResponse o) {
   buildCounterListJobMessagesResponse++;
   if (buildCounterListJobMessagesResponse < 3) {
-    checkUnnamed3164(o.jobMessages);
+    checkUnnamed3004(o.jobMessages);
     unittest.expect(o.nextPageToken, unittest.equals('foo'));
   }
   buildCounterListJobMessagesResponse--;
 }
 
-buildUnnamed3165() {
+buildUnnamed3005() {
   var o = new core.List<api.FailedLocation>();
   o.add(buildFailedLocation());
   o.add(buildFailedLocation());
   return o;
 }
 
-checkUnnamed3165(core.List<api.FailedLocation> o) {
+checkUnnamed3005(core.List<api.FailedLocation> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkFailedLocation(o[0]);
   checkFailedLocation(o[1]);
 }
 
-buildUnnamed3166() {
+buildUnnamed3006() {
   var o = new core.List<api.Job>();
   o.add(buildJob());
   o.add(buildJob());
   return o;
 }
 
-checkUnnamed3166(core.List<api.Job> o) {
+checkUnnamed3006(core.List<api.Job> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkJob(o[0]);
   checkJob(o[1]);
@@ -1380,8 +1630,8 @@ buildListJobsResponse() {
   var o = new api.ListJobsResponse();
   buildCounterListJobsResponse++;
   if (buildCounterListJobsResponse < 3) {
-    o.failedLocation = buildUnnamed3165();
-    o.jobs = buildUnnamed3166();
+    o.failedLocation = buildUnnamed3005();
+    o.jobs = buildUnnamed3006();
     o.nextPageToken = "foo";
   }
   buildCounterListJobsResponse--;
@@ -1391,21 +1641,21 @@ buildListJobsResponse() {
 checkListJobsResponse(api.ListJobsResponse o) {
   buildCounterListJobsResponse++;
   if (buildCounterListJobsResponse < 3) {
-    checkUnnamed3165(o.failedLocation);
-    checkUnnamed3166(o.jobs);
+    checkUnnamed3005(o.failedLocation);
+    checkUnnamed3006(o.jobs);
     unittest.expect(o.nextPageToken, unittest.equals('foo'));
   }
   buildCounterListJobsResponse--;
 }
 
-buildUnnamed3167() {
+buildUnnamed3007() {
   var o = new core.List<api.ParallelInstruction>();
   o.add(buildParallelInstruction());
   o.add(buildParallelInstruction());
   return o;
 }
 
-checkUnnamed3167(core.List<api.ParallelInstruction> o) {
+checkUnnamed3007(core.List<api.ParallelInstruction> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkParallelInstruction(o[0]);
   checkParallelInstruction(o[1]);
@@ -1416,7 +1666,7 @@ buildMapTask() {
   var o = new api.MapTask();
   buildCounterMapTask++;
   if (buildCounterMapTask < 3) {
-    o.instructions = buildUnnamed3167();
+    o.instructions = buildUnnamed3007();
     o.stageName = "foo";
     o.systemName = "foo";
   }
@@ -1427,7 +1677,7 @@ buildMapTask() {
 checkMapTask(api.MapTask o) {
   buildCounterMapTask++;
   if (buildCounterMapTask < 3) {
-    checkUnnamed3167(o.instructions);
+    checkUnnamed3007(o.instructions);
     unittest.expect(o.stageName, unittest.equals('foo'));
     unittest.expect(o.systemName, unittest.equals('foo'));
   }
@@ -1455,14 +1705,14 @@ checkMetricShortId(api.MetricShortId o) {
   buildCounterMetricShortId--;
 }
 
-buildUnnamed3168() {
+buildUnnamed3008() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3168(core.Map<core.String, core.String> o) {
+checkUnnamed3008(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'));
@@ -1473,7 +1723,7 @@ buildMetricStructuredName() {
   var o = new api.MetricStructuredName();
   buildCounterMetricStructuredName++;
   if (buildCounterMetricStructuredName < 3) {
-    o.context = buildUnnamed3168();
+    o.context = buildUnnamed3008();
     o.name = "foo";
     o.origin = "foo";
   }
@@ -1484,7 +1734,7 @@ buildMetricStructuredName() {
 checkMetricStructuredName(api.MetricStructuredName o) {
   buildCounterMetricStructuredName++;
   if (buildCounterMetricStructuredName < 3) {
-    checkUnnamed3168(o.context);
+    checkUnnamed3008(o.context);
     unittest.expect(o.name, unittest.equals('foo'));
     unittest.expect(o.origin, unittest.equals('foo'));
   }
@@ -1606,40 +1856,40 @@ checkPackage(api.Package o) {
   buildCounterPackage--;
 }
 
-buildUnnamed3169() {
+buildUnnamed3009() {
   var o = new core.List<api.MultiOutputInfo>();
   o.add(buildMultiOutputInfo());
   o.add(buildMultiOutputInfo());
   return o;
 }
 
-checkUnnamed3169(core.List<api.MultiOutputInfo> o) {
+checkUnnamed3009(core.List<api.MultiOutputInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkMultiOutputInfo(o[0]);
   checkMultiOutputInfo(o[1]);
 }
 
-buildUnnamed3170() {
+buildUnnamed3010() {
   var o = new core.List<api.SideInputInfo>();
   o.add(buildSideInputInfo());
   o.add(buildSideInputInfo());
   return o;
 }
 
-checkUnnamed3170(core.List<api.SideInputInfo> o) {
+checkUnnamed3010(core.List<api.SideInputInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSideInputInfo(o[0]);
   checkSideInputInfo(o[1]);
 }
 
-buildUnnamed3171() {
+buildUnnamed3011() {
   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;
 }
 
-checkUnnamed3171(core.Map<core.String, core.Object> o) {
+checkUnnamed3011(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')); 
@@ -1651,10 +1901,10 @@ buildParDoInstruction() {
   buildCounterParDoInstruction++;
   if (buildCounterParDoInstruction < 3) {
     o.input = buildInstructionInput();
-    o.multiOutputInfos = buildUnnamed3169();
+    o.multiOutputInfos = buildUnnamed3009();
     o.numOutputs = 42;
-    o.sideInputs = buildUnnamed3170();
-    o.userFn = buildUnnamed3171();
+    o.sideInputs = buildUnnamed3010();
+    o.userFn = buildUnnamed3011();
   }
   buildCounterParDoInstruction--;
   return o;
@@ -1664,22 +1914,22 @@ checkParDoInstruction(api.ParDoInstruction o) {
   buildCounterParDoInstruction++;
   if (buildCounterParDoInstruction < 3) {
     checkInstructionInput(o.input);
-    checkUnnamed3169(o.multiOutputInfos);
+    checkUnnamed3009(o.multiOutputInfos);
     unittest.expect(o.numOutputs, unittest.equals(42));
-    checkUnnamed3170(o.sideInputs);
-    checkUnnamed3171(o.userFn);
+    checkUnnamed3010(o.sideInputs);
+    checkUnnamed3011(o.userFn);
   }
   buildCounterParDoInstruction--;
 }
 
-buildUnnamed3172() {
+buildUnnamed3012() {
   var o = new core.List<api.InstructionOutput>();
   o.add(buildInstructionOutput());
   o.add(buildInstructionOutput());
   return o;
 }
 
-checkUnnamed3172(core.List<api.InstructionOutput> o) {
+checkUnnamed3012(core.List<api.InstructionOutput> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkInstructionOutput(o[0]);
   checkInstructionOutput(o[1]);
@@ -1693,7 +1943,7 @@ buildParallelInstruction() {
     o.flatten = buildFlattenInstruction();
     o.name = "foo";
     o.originalName = "foo";
-    o.outputs = buildUnnamed3172();
+    o.outputs = buildUnnamed3012();
     o.parDo = buildParDoInstruction();
     o.partialGroupByKey = buildPartialGroupByKeyInstruction();
     o.read = buildReadInstruction();
@@ -1710,7 +1960,7 @@ checkParallelInstruction(api.ParallelInstruction o) {
     checkFlattenInstruction(o.flatten);
     unittest.expect(o.name, unittest.equals('foo'));
     unittest.expect(o.originalName, unittest.equals('foo'));
-    checkUnnamed3172(o.outputs);
+    checkUnnamed3012(o.outputs);
     checkParDoInstruction(o.parDo);
     checkPartialGroupByKeyInstruction(o.partialGroupByKey);
     checkReadInstruction(o.read);
@@ -1720,40 +1970,80 @@ checkParallelInstruction(api.ParallelInstruction o) {
   buildCounterParallelInstruction--;
 }
 
-buildUnnamed3173() {
+buildUnnamed3013() {
+  var o = new core.List<core.String>();
+  o.add("foo");
+  o.add("foo");
+  return o;
+}
+
+checkUnnamed3013(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 = buildUnnamed3013();
+  }
+  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'));
+    checkUnnamed3013(o.regexes);
+  }
+  buildCounterParameterMetadata--;
+}
+
+buildUnnamed3014() {
   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;
 }
 
-checkUnnamed3173(core.Map<core.String, core.Object> o) {
+checkUnnamed3014(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')); 
 }
 
-buildUnnamed3174() {
+buildUnnamed3015() {
   var o = new core.List<api.SideInputInfo>();
   o.add(buildSideInputInfo());
   o.add(buildSideInputInfo());
   return o;
 }
 
-checkUnnamed3174(core.List<api.SideInputInfo> o) {
+checkUnnamed3015(core.List<api.SideInputInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSideInputInfo(o[0]);
   checkSideInputInfo(o[1]);
 }
 
-buildUnnamed3175() {
+buildUnnamed3016() {
   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) {
+checkUnnamed3016(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')); 
@@ -1765,11 +2055,11 @@ buildPartialGroupByKeyInstruction() {
   buildCounterPartialGroupByKeyInstruction++;
   if (buildCounterPartialGroupByKeyInstruction < 3) {
     o.input = buildInstructionInput();
-    o.inputElementCodec = buildUnnamed3173();
+    o.inputElementCodec = buildUnnamed3014();
     o.originalCombineValuesInputStoreName = "foo";
     o.originalCombineValuesStepName = "foo";
-    o.sideInputs = buildUnnamed3174();
-    o.valueCombiningFn = buildUnnamed3175();
+    o.sideInputs = buildUnnamed3015();
+    o.valueCombiningFn = buildUnnamed3016();
   }
   buildCounterPartialGroupByKeyInstruction--;
   return o;
@@ -1779,15 +2069,77 @@ checkPartialGroupByKeyInstruction(api.PartialGroupByKeyInstruction o) {
   buildCounterPartialGroupByKeyInstruction++;
   if (buildCounterPartialGroupByKeyInstruction < 3) {
     checkInstructionInput(o.input);
-    checkUnnamed3173(o.inputElementCodec);
+    checkUnnamed3014(o.inputElementCodec);
     unittest.expect(o.originalCombineValuesInputStoreName, unittest.equals('foo'));
     unittest.expect(o.originalCombineValuesStepName, unittest.equals('foo'));
-    checkUnnamed3174(o.sideInputs);
-    checkUnnamed3175(o.valueCombiningFn);
+    checkUnnamed3015(o.sideInputs);
+    checkUnnamed3016(o.valueCombiningFn);
   }
   buildCounterPartialGroupByKeyInstruction--;
 }
 
+buildUnnamed3017() {
+  var o = new core.List<api.DisplayData>();
+  o.add(buildDisplayData());
+  o.add(buildDisplayData());
+  return o;
+}
+
+checkUnnamed3017(core.List<api.DisplayData> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  checkDisplayData(o[0]);
+  checkDisplayData(o[1]);
+}
+
+buildUnnamed3018() {
+  var o = new core.List<api.ExecutionStageSummary>();
+  o.add(buildExecutionStageSummary());
+  o.add(buildExecutionStageSummary());
+  return o;
+}
+
+checkUnnamed3018(core.List<api.ExecutionStageSummary> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  checkExecutionStageSummary(o[0]);
+  checkExecutionStageSummary(o[1]);
+}
+
+buildUnnamed3019() {
+  var o = new core.List<api.TransformSummary>();
+  o.add(buildTransformSummary());
+  o.add(buildTransformSummary());
+  return o;
+}
+
+checkUnnamed3019(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 = buildUnnamed3017();
+    o.executionPipelineStage = buildUnnamed3018();
+    o.originalPipelineTransform = buildUnnamed3019();
+  }
+  buildCounterPipelineDescription--;
+  return o;
+}
+
+checkPipelineDescription(api.PipelineDescription o) {
+  buildCounterPipelineDescription++;
+  if (buildCounterPipelineDescription < 3) {
+    checkUnnamed3017(o.displayData);
+    checkUnnamed3018(o.executionPipelineStage);
+    checkUnnamed3019(o.originalPipelineTransform);
+  }
+  buildCounterPipelineDescription--;
+}
+
 core.int buildCounterPosition = 0;
 buildPosition() {
   var o = new api.Position();
@@ -1867,14 +2219,14 @@ checkReadInstruction(api.ReadInstruction o) {
   buildCounterReadInstruction--;
 }
 
-buildUnnamed3176() {
+buildUnnamed3020() {
   var o = new core.List<api.WorkItemStatus>();
   o.add(buildWorkItemStatus());
   o.add(buildWorkItemStatus());
   return o;
 }
 
-checkUnnamed3176(core.List<api.WorkItemStatus> o) {
+checkUnnamed3020(core.List<api.WorkItemStatus> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkItemStatus(o[0]);
   checkWorkItemStatus(o[1]);
@@ -1887,7 +2239,7 @@ buildReportWorkItemStatusRequest() {
   if (buildCounterReportWorkItemStatusRequest < 3) {
     o.currentWorkerTime = "foo";
     o.location = "foo";
-    o.workItemStatuses = buildUnnamed3176();
+    o.workItemStatuses = buildUnnamed3020();
     o.workerId = "foo";
   }
   buildCounterReportWorkItemStatusRequest--;
@@ -1899,20 +2251,20 @@ checkReportWorkItemStatusRequest(api.ReportWorkItemStatusRequest o) {
   if (buildCounterReportWorkItemStatusRequest < 3) {
     unittest.expect(o.currentWorkerTime, unittest.equals('foo'));
     unittest.expect(o.location, unittest.equals('foo'));
-    checkUnnamed3176(o.workItemStatuses);
+    checkUnnamed3020(o.workItemStatuses);
     unittest.expect(o.workerId, unittest.equals('foo'));
   }
   buildCounterReportWorkItemStatusRequest--;
 }
 
-buildUnnamed3177() {
+buildUnnamed3021() {
   var o = new core.List<api.WorkItemServiceState>();
   o.add(buildWorkItemServiceState());
   o.add(buildWorkItemServiceState());
   return o;
 }
 
-checkUnnamed3177(core.List<api.WorkItemServiceState> o) {
+checkUnnamed3021(core.List<api.WorkItemServiceState> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkItemServiceState(o[0]);
   checkWorkItemServiceState(o[1]);
@@ -1923,7 +2275,7 @@ buildReportWorkItemStatusResponse() {
   var o = new api.ReportWorkItemStatusResponse();
   buildCounterReportWorkItemStatusResponse++;
   if (buildCounterReportWorkItemStatusResponse < 3) {
-    o.workItemServiceStates = buildUnnamed3177();
+    o.workItemServiceStates = buildUnnamed3021();
   }
   buildCounterReportWorkItemStatusResponse--;
   return o;
@@ -1932,7 +2284,7 @@ buildReportWorkItemStatusResponse() {
 checkReportWorkItemStatusResponse(api.ReportWorkItemStatusResponse o) {
   buildCounterReportWorkItemStatusResponse++;
   if (buildCounterReportWorkItemStatusResponse < 3) {
-    checkUnnamed3177(o.workItemServiceStates);
+    checkUnnamed3021(o.workItemServiceStates);
   }
   buildCounterReportWorkItemStatusResponse--;
 }
@@ -1958,14 +2310,14 @@ checkReportedParallelism(api.ReportedParallelism o) {
   buildCounterReportedParallelism--;
 }
 
-buildUnnamed3178() {
+buildUnnamed3022() {
   var o = new core.List<api.CPUTime>();
   o.add(buildCPUTime());
   o.add(buildCPUTime());
   return o;
 }
 
-checkUnnamed3178(core.List<api.CPUTime> o) {
+checkUnnamed3022(core.List<api.CPUTime> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkCPUTime(o[0]);
   checkCPUTime(o[1]);
@@ -1976,7 +2328,7 @@ buildResourceUtilizationReport() {
   var o = new api.ResourceUtilizationReport();
   buildCounterResourceUtilizationReport++;
   if (buildCounterResourceUtilizationReport < 3) {
-    o.cpuTime = buildUnnamed3178();
+    o.cpuTime = buildUnnamed3022();
   }
   buildCounterResourceUtilizationReport--;
   return o;
@@ -1985,7 +2337,7 @@ buildResourceUtilizationReport() {
 checkResourceUtilizationReport(api.ResourceUtilizationReport o) {
   buildCounterResourceUtilizationReport++;
   if (buildCounterResourceUtilizationReport < 3) {
-    checkUnnamed3178(o.cpuTime);
+    checkUnnamed3022(o.cpuTime);
   }
   buildCounterResourceUtilizationReport--;
 }
@@ -2074,14 +2426,14 @@ checkSendDebugCaptureResponse(api.SendDebugCaptureResponse o) {
   buildCounterSendDebugCaptureResponse--;
 }
 
-buildUnnamed3179() {
+buildUnnamed3023() {
   var o = new core.List<api.WorkerMessage>();
   o.add(buildWorkerMessage());
   o.add(buildWorkerMessage());
   return o;
 }
 
-checkUnnamed3179(core.List<api.WorkerMessage> o) {
+checkUnnamed3023(core.List<api.WorkerMessage> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkerMessage(o[0]);
   checkWorkerMessage(o[1]);
@@ -2092,7 +2444,7 @@ buildSendWorkerMessagesRequest() {
   var o = new api.SendWorkerMessagesRequest();
   buildCounterSendWorkerMessagesRequest++;
   if (buildCounterSendWorkerMessagesRequest < 3) {
-    o.workerMessages = buildUnnamed3179();
+    o.workerMessages = buildUnnamed3023();
   }
   buildCounterSendWorkerMessagesRequest--;
   return o;
@@ -2101,19 +2453,19 @@ buildSendWorkerMessagesRequest() {
 checkSendWorkerMessagesRequest(api.SendWorkerMessagesRequest o) {
   buildCounterSendWorkerMessagesRequest++;
   if (buildCounterSendWorkerMessagesRequest < 3) {
-    checkUnnamed3179(o.workerMessages);
+    checkUnnamed3023(o.workerMessages);
   }
   buildCounterSendWorkerMessagesRequest--;
 }
 
-buildUnnamed3180() {
+buildUnnamed3024() {
   var o = new core.List<api.WorkerMessageResponse>();
   o.add(buildWorkerMessageResponse());
   o.add(buildWorkerMessageResponse());
   return o;
 }
 
-checkUnnamed3180(core.List<api.WorkerMessageResponse> o) {
+checkUnnamed3024(core.List<api.WorkerMessageResponse> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkWorkerMessageResponse(o[0]);
   checkWorkerMessageResponse(o[1]);
@@ -2124,7 +2476,7 @@ buildSendWorkerMessagesResponse() {
   var o = new api.SendWorkerMessagesResponse();
   buildCounterSendWorkerMessagesResponse++;
   if (buildCounterSendWorkerMessagesResponse < 3) {
-    o.workerMessageResponses = buildUnnamed3180();
+    o.workerMessageResponses = buildUnnamed3024();
   }
   buildCounterSendWorkerMessagesResponse--;
   return o;
@@ -2133,45 +2485,45 @@ buildSendWorkerMessagesResponse() {
 checkSendWorkerMessagesResponse(api.SendWorkerMessagesResponse o) {
   buildCounterSendWorkerMessagesResponse++;
   if (buildCounterSendWorkerMessagesResponse < 3) {
-    checkUnnamed3180(o.workerMessageResponses);
+    checkUnnamed3024(o.workerMessageResponses);
   }
   buildCounterSendWorkerMessagesResponse--;
 }
 
-buildUnnamed3181() {
+buildUnnamed3025() {
   var o = new core.List<api.SideInputInfo>();
   o.add(buildSideInputInfo());
   o.add(buildSideInputInfo());
   return o;
 }
 
-checkUnnamed3181(core.List<api.SideInputInfo> o) {
+checkUnnamed3025(core.List<api.SideInputInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSideInputInfo(o[0]);
   checkSideInputInfo(o[1]);
 }
 
-buildUnnamed3182() {
+buildUnnamed3026() {
   var o = new core.List<api.SeqMapTaskOutputInfo>();
   o.add(buildSeqMapTaskOutputInfo());
   o.add(buildSeqMapTaskOutputInfo());
   return o;
 }
 
-checkUnnamed3182(core.List<api.SeqMapTaskOutputInfo> o) {
+checkUnnamed3026(core.List<api.SeqMapTaskOutputInfo> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSeqMapTaskOutputInfo(o[0]);
   checkSeqMapTaskOutputInfo(o[1]);
 }
 
-buildUnnamed3183() {
+buildUnnamed3027() {
   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;
 }
 
-checkUnnamed3183(core.Map<core.String, core.Object> o) {
+checkUnnamed3027(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')); 
@@ -2182,12 +2534,12 @@ buildSeqMapTask() {
   var o = new api.SeqMapTask();
   buildCounterSeqMapTask++;
   if (buildCounterSeqMapTask < 3) {
-    o.inputs = buildUnnamed3181();
+    o.inputs = buildUnnamed3025();
     o.name = "foo";
-    o.outputInfos = buildUnnamed3182();
+    o.outputInfos = buildUnnamed3026();
     o.stageName = "foo";
     o.systemName = "foo";
-    o.userFn = buildUnnamed3183();
+    o.userFn = buildUnnamed3027();
   }
   buildCounterSeqMapTask--;
   return o;
@@ -2196,12 +2548,12 @@ buildSeqMapTask() {
 checkSeqMapTask(api.SeqMapTask o) {
   buildCounterSeqMapTask++;
   if (buildCounterSeqMapTask < 3) {
-    checkUnnamed3181(o.inputs);
+    checkUnnamed3025(o.inputs);
     unittest.expect(o.name, unittest.equals('foo'));
-    checkUnnamed3182(o.outputInfos);
+    checkUnnamed3026(o.outputInfos);
     unittest.expect(o.stageName, unittest.equals('foo'));
     unittest.expect(o.systemName, unittest.equals('foo'));
-    checkUnnamed3183(o.userFn);
+    checkUnnamed3027(o.userFn);
   }
   buildCounterSeqMapTask--;
 }
@@ -2248,27 +2600,27 @@ checkShellTask(api.ShellTask o) {
   buildCounterShellTask--;
 }
 
-buildUnnamed3184() {
+buildUnnamed3028() {
   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;
 }
 
-checkUnnamed3184(core.Map<core.String, core.Object> o) {
+checkUnnamed3028(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')); 
 }
 
-buildUnnamed3185() {
+buildUnnamed3029() {
   var o = new core.List<api.Source>();
   o.add(buildSource());
   o.add(buildSource());
   return o;
 }
 
-checkUnnamed3185(core.List<api.Source> o) {
+checkUnnamed3029(core.List<api.Source> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSource(o[0]);
   checkSource(o[1]);
@@ -2279,8 +2631,8 @@ buildSideInputInfo() {
   var o = new api.SideInputInfo();
   buildCounterSideInputInfo++;
   if (buildCounterSideInputInfo < 3) {
-    o.kind = buildUnnamed3184();
-    o.sources = buildUnnamed3185();
+    o.kind = buildUnnamed3028();
+    o.sources = buildUnnamed3029();
     o.tag = "foo";
   }
   buildCounterSideInputInfo--;
@@ -2290,34 +2642,34 @@ buildSideInputInfo() {
 checkSideInputInfo(api.SideInputInfo o) {
   buildCounterSideInputInfo++;
   if (buildCounterSideInputInfo < 3) {
-    checkUnnamed3184(o.kind);
-    checkUnnamed3185(o.sources);
+    checkUnnamed3028(o.kind);
+    checkUnnamed3029(o.sources);
     unittest.expect(o.tag, unittest.equals('foo'));
   }
   buildCounterSideInputInfo--;
 }
 
-buildUnnamed3186() {
+buildUnnamed3030() {
   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;
 }
 
-checkUnnamed3186(core.Map<core.String, core.Object> o) {
+checkUnnamed3030(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')); 
 }
 
-buildUnnamed3187() {
+buildUnnamed3031() {
   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;
 }
 
-checkUnnamed3187(core.Map<core.String, core.Object> o) {
+checkUnnamed3031(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')); 
@@ -2328,8 +2680,8 @@ buildSink() {
   var o = new api.Sink();
   buildCounterSink++;
   if (buildCounterSink < 3) {
-    o.codec = buildUnnamed3186();
-    o.spec = buildUnnamed3187();
+    o.codec = buildUnnamed3030();
+    o.spec = buildUnnamed3031();
   }
   buildCounterSink--;
   return o;
@@ -2338,59 +2690,59 @@ buildSink() {
 checkSink(api.Sink o) {
   buildCounterSink++;
   if (buildCounterSink < 3) {
-    checkUnnamed3186(o.codec);
-    checkUnnamed3187(o.spec);
+    checkUnnamed3030(o.codec);
+    checkUnnamed3031(o.spec);
   }
   buildCounterSink--;
 }
 
-buildUnnamed3188() {
+buildUnnamed3032() {
   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;
 }
 
-checkUnnamed3188(core.Map<core.String, core.Object> o) {
+checkUnnamed3032(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')); 
 }
 
-buildUnnamed3189() {
+buildUnnamed3033() {
   var o = new core.List<core.Map<core.String, core.Object>>();
-  o.add(buildUnnamed3188());
-  o.add(buildUnnamed3188());
+  o.add(buildUnnamed3032());
+  o.add(buildUnnamed3032());
   return o;
 }
 
-checkUnnamed3189(core.List<core.Map<core.String, core.Object>> o) {
+checkUnnamed3033(core.List<core.Map<core.String, core.Object>> o) {
   unittest.expect(o, unittest.hasLength(2));
-  checkUnnamed3188(o[0]);
-  checkUnnamed3188(o[1]);
+  checkUnnamed3032(o[0]);
+  checkUnnamed3032(o[1]);
 }
 
-buildUnnamed3190() {
+buildUnnamed3034() {
   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;
 }
 
-checkUnnamed3190(core.Map<core.String, core.Object> o) {
+checkUnnamed3034(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')); 
 }
 
-buildUnnamed3191() {
+buildUnnamed3035() {
   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;
 }
 
-checkUnnamed3191(core.Map<core.String, core.Object> o) {
+checkUnnamed3035(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')); 
@@ -2401,11 +2753,11 @@ buildSource() {
   var o = new api.Source();
   buildCounterSource++;
   if (buildCounterSource < 3) {
-    o.baseSpecs = buildUnnamed3189();
-    o.codec = buildUnnamed3190();
+    o.baseSpecs = buildUnnamed3033();
+    o.codec = buildUnnamed3034();
     o.doesNotNeedSplitting = true;
     o.metadata = buildSourceMetadata();
-    o.spec = buildUnnamed3191();
+    o.spec = buildUnnamed3035();
   }
   buildCounterSource--;
   return o;
@@ -2414,11 +2766,11 @@ buildSource() {
 checkSource(api.Source o) {
   buildCounterSource++;
   if (buildCounterSource < 3) {
-    checkUnnamed3189(o.baseSpecs);
-    checkUnnamed3190(o.codec);
+    checkUnnamed3033(o.baseSpecs);
+    checkUnnamed3034(o.codec);
     unittest.expect(o.doesNotNeedSplitting, unittest.isTrue);
     checkSourceMetadata(o.metadata);
-    checkUnnamed3191(o.spec);
+    checkUnnamed3035(o.spec);
   }
   buildCounterSource--;
 }
@@ -2593,27 +2945,27 @@ checkSourceSplitRequest(api.SourceSplitRequest o) {
   buildCounterSourceSplitRequest--;
 }
 
-buildUnnamed3192() {
+buildUnnamed3036() {
   var o = new core.List<api.DerivedSource>();
   o.add(buildDerivedSource());
   o.add(buildDerivedSource());
   return o;
 }
 
-checkUnnamed3192(core.List<api.DerivedSource> o) {
+checkUnnamed3036(core.List<api.DerivedSource> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkDerivedSource(o[0]);
   checkDerivedSource(o[1]);
 }
 
-buildUnnamed3193() {
+buildUnnamed3037() {
   var o = new core.List<api.SourceSplitShard>();
   o.add(buildSourceSplitShard());
   o.add(buildSourceSplitShard());
   return o;
 }
 
-checkUnnamed3193(core.List<api.SourceSplitShard> o) {
+checkUnnamed3037(core.List<api.SourceSplitShard> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSourceSplitShard(o[0]);
   checkSourceSplitShard(o[1]);
@@ -2624,9 +2976,9 @@ buildSourceSplitResponse() {
   var o = new api.SourceSplitResponse();
   buildCounterSourceSplitResponse++;
   if (buildCounterSourceSplitResponse < 3) {
-    o.bundles = buildUnnamed3192();
+    o.bundles = buildUnnamed3036();
     o.outcome = "foo";
-    o.shards = buildUnnamed3193();
+    o.shards = buildUnnamed3037();
   }
   buildCounterSourceSplitResponse--;
   return o;
@@ -2635,9 +2987,9 @@ buildSourceSplitResponse() {
 checkSourceSplitResponse(api.SourceSplitResponse o) {
   buildCounterSourceSplitResponse++;
   if (buildCounterSourceSplitResponse < 3) {
-    checkUnnamed3192(o.bundles);
+    checkUnnamed3036(o.bundles);
     unittest.expect(o.outcome, unittest.equals('foo'));
-    checkUnnamed3193(o.shards);
+    checkUnnamed3037(o.shards);
   }
   buildCounterSourceSplitResponse--;
 }
@@ -2684,6 +3036,31 @@ checkSplitInt64(api.SplitInt64 o) {
   buildCounterSplitInt64--;
 }
 
+core.int buildCounterStageSource = 0;
+buildStageSource() {
+  var o = new api.StageSource();
+  buildCounterStageSource++;
+  if (buildCounterStageSource < 3) {
+    o.name = "foo";
+    o.originalTransformOrCollection = "foo";
+    o.sizeBytes = "foo";
+    o.userName = "foo";
+  }
+  buildCounterStageSource--;
+  return o;
+}
+
+checkStageSource(api.StageSource o) {
+  buildCounterStageSource++;
+  if (buildCounterStageSource < 3) {
+    unittest.expect(o.name, unittest.equals('foo'));
+    unittest.expect(o.originalTransformOrCollection, unittest.equals('foo'));
+    unittest.expect(o.sizeBytes, unittest.equals('foo'));
+    unittest.expect(o.userName, unittest.equals('foo'));
+  }
+  buildCounterStageSource--;
+}
+
 core.int buildCounterStateFamilyConfig = 0;
 buildStateFamilyConfig() {
   var o = new api.StateFamilyConfig();
@@ -2705,30 +3082,30 @@ checkStateFamilyConfig(api.StateFamilyConfig o) {
   buildCounterStateFamilyConfig--;
 }
 
-buildUnnamed3194() {
+buildUnnamed3038() {
   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;
 }
 
-checkUnnamed3194(core.Map<core.String, core.Object> o) {
+checkUnnamed3038(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')); 
 }
 
-buildUnnamed3195() {
+buildUnnamed3039() {
   var o = new core.List<core.Map<core.String, core.Object>>();
-  o.add(buildUnnamed3194());
-  o.add(buildUnnamed3194());
+  o.add(buildUnnamed3038());
+  o.add(buildUnnamed3038());
   return o;
 }
 
-checkUnnamed3195(core.List<core.Map<core.String, core.Object>> o) {
+checkUnnamed3039(core.List<core.Map<core.String, core.Object>> o) {
   unittest.expect(o, unittest.hasLength(2));
-  checkUnnamed3194(o[0]);
-  checkUnnamed3194(o[1]);
+  checkUnnamed3038(o[0]);
+  checkUnnamed3038(o[1]);
 }
 
 core.int buildCounterStatus = 0;
@@ -2737,7 +3114,7 @@ buildStatus() {
   buildCounterStatus++;
   if (buildCounterStatus < 3) {
     o.code = 42;
-    o.details = buildUnnamed3195();
+    o.details = buildUnnamed3039();
     o.message = "foo";
   }
   buildCounterStatus--;
@@ -2748,20 +3125,20 @@ checkStatus(api.Status o) {
   buildCounterStatus++;
   if (buildCounterStatus < 3) {
     unittest.expect(o.code, unittest.equals(42));
-    checkUnnamed3195(o.details);
+    checkUnnamed3039(o.details);
     unittest.expect(o.message, unittest.equals('foo'));
   }
   buildCounterStatus--;
 }
 
-buildUnnamed3196() {
+buildUnnamed3040() {
   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;
 }
 
-checkUnnamed3196(core.Map<core.String, core.Object> o) {
+checkUnnamed3040(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')); 
@@ -2774,7 +3151,7 @@ buildStep() {
   if (buildCounterStep < 3) {
     o.kind = "foo";
     o.name = "foo";
-    o.properties = buildUnnamed3196();
+    o.properties = buildUnnamed3040();
   }
   buildCounterStep--;
   return o;
@@ -2785,7 +3162,7 @@ checkStep(api.Step o) {
   if (buildCounterStep < 3) {
     unittest.expect(o.kind, unittest.equals('foo'));
     unittest.expect(o.name, unittest.equals('foo'));
-    checkUnnamed3196(o.properties);
+    checkUnnamed3040(o.properties);
   }
   buildCounterStep--;
 }
@@ -2815,14 +3192,14 @@ checkStreamLocation(api.StreamLocation o) {
   buildCounterStreamLocation--;
 }
 
-buildUnnamed3197() {
+buildUnnamed3041() {
   var o = new core.List<api.ParallelInstruction>();
   o.add(buildParallelInstruction());
   o.add(buildParallelInstruction());
   return o;
 }
 
-checkUnnamed3197(core.List<api.ParallelInstruction> o) {
+checkUnnamed3041(core.List<api.ParallelInstruction> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkParallelInstruction(o[0]);
   checkParallelInstruction(o[1]);
@@ -2834,7 +3211,7 @@ buildStreamingComputationConfig() {
   buildCounterStreamingComputationConfig++;
   if (buildCounterStreamingComputationConfig < 3) {
     o.computationId = "foo";
-    o.instructions = buildUnnamed3197();
+    o.instructions = buildUnnamed3041();
     o.stageName = "foo";
     o.systemName = "foo";
   }
@@ -2846,21 +3223,21 @@ checkStreamingComputationConfig(api.StreamingComputationConfig o) {
   buildCounterStreamingComputationConfig++;
   if (buildCounterStreamingComputationConfig < 3) {
     unittest.expect(o.computationId, unittest.equals('foo'));
-    checkUnnamed3197(o.instructions);
+    checkUnnamed3041(o.instructions);
     unittest.expect(o.stageName, unittest.equals('foo'));
     unittest.expect(o.systemName, unittest.equals('foo'));
   }
   buildCounterStreamingComputationConfig--;
 }
 
-buildUnnamed3198() {
+buildUnnamed3042() {
   var o = new core.List<api.KeyRangeDataDiskAssignment>();
   o.add(buildKeyRangeDataDiskAssignment());
   o.add(buildKeyRangeDataDiskAssignment());
   return o;
 }
 
-checkUnnamed3198(core.List<api.KeyRangeDataDiskAssignment> o) {
+checkUnnamed3042(core.List<api.KeyRangeDataDiskAssignment> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkKeyRangeDataDiskAssignment(o[0]);
   checkKeyRangeDataDiskAssignment(o[1]);
@@ -2872,7 +3249,7 @@ buildStreamingComputationRanges() {
   buildCounterStreamingComputationRanges++;
   if (buildCounterStreamingComputationRanges < 3) {
     o.computationId = "foo";
-    o.rangeAssignments = buildUnnamed3198();
+    o.rangeAssignments = buildUnnamed3042();
   }
   buildCounterStreamingComputationRanges--;
   return o;
@@ -2882,32 +3259,32 @@ checkStreamingComputationRanges(api.StreamingComputationRanges o) {
   buildCounterStreamingComputationRanges++;
   if (buildCounterStreamingComputationRanges < 3) {
     unittest.expect(o.computationId, unittest.equals('foo'));
-    checkUnnamed3198(o.rangeAssignments);
+    checkUnnamed3042(o.rangeAssignments);
   }
   buildCounterStreamingComputationRanges--;
 }
 
-buildUnnamed3199() {
+buildUnnamed3043() {
   var o = new core.List<api.StreamingComputationRanges>();
   o.add(buildStreamingComputationRanges());
   o.add(buildStreamingComputationRanges());
   return o;
 }
 
-checkUnnamed3199(core.List<api.StreamingComputationRanges> o) {
+checkUnnamed3043(core.List<api.StreamingComputationRanges> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStreamingComputationRanges(o[0]);
   checkStreamingComputationRanges(o[1]);
 }
 
-buildUnnamed3200() {
+buildUnnamed3044() {
   var o = new core.List<api.MountedDataDisk>();
   o.add(buildMountedDataDisk());
   o.add(buildMountedDataDisk());
   return o;
 }
 
-checkUnnamed3200(core.List<api.MountedDataDisk> o) {
+checkUnnamed3044(core.List<api.MountedDataDisk> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkMountedDataDisk(o[0]);
   checkMountedDataDisk(o[1]);
@@ -2918,8 +3295,8 @@ buildStreamingComputationTask() {
   var o = new api.StreamingComputationTask();
   buildCounterStreamingComputationTask++;
   if (buildCounterStreamingComputationTask < 3) {
-    o.computationRanges = buildUnnamed3199();
-    o.dataDisks = buildUnnamed3200();
+    o.computationRanges = buildUnnamed3043();
+    o.dataDisks = buildUnnamed3044();
     o.taskType = "foo";
   }
   buildCounterStreamingComputationTask--;
@@ -2929,34 +3306,34 @@ buildStreamingComputationTask() {
 checkStreamingComputationTask(api.StreamingComputationTask o) {
   buildCounterStreamingComputationTask++;
   if (buildCounterStreamingComputationTask < 3) {
-    checkUnnamed3199(o.computationRanges);
-    checkUnnamed3200(o.dataDisks);
+    checkUnnamed3043(o.computationRanges);
+    checkUnnamed3044(o.dataDisks);
     unittest.expect(o.taskType, unittest.equals('foo'));
   }
   buildCounterStreamingComputationTask--;
 }
 
-buildUnnamed3201() {
+buildUnnamed3045() {
   var o = new core.List<api.StreamingComputationConfig>();
   o.add(buildStreamingComputationConfig());
   o.add(buildStreamingComputationConfig());
   return o;
 }
 
-checkUnnamed3201(core.List<api.StreamingComputationConfig> o) {
+checkUnnamed3045(core.List<api.StreamingComputationConfig> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStreamingComputationConfig(o[0]);
   checkStreamingComputationConfig(o[1]);
 }
 
-buildUnnamed3202() {
+buildUnnamed3046() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3202(core.Map<core.String, core.String> o) {
+checkUnnamed3046(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'));
@@ -2967,8 +3344,8 @@ buildStreamingConfigTask() {
   var o = new api.StreamingConfigTask();
   buildCounterStreamingConfigTask++;
   if (buildCounterStreamingConfigTask < 3) {
-    o.streamingComputationConfigs = buildUnnamed3201();
-    o.userStepToStateFamilyNameMap = buildUnnamed3202();
+    o.streamingComputationConfigs = buildUnnamed3045();
+    o.userStepToStateFamilyNameMap = buildUnnamed3046();
   }
   buildCounterStreamingConfigTask--;
   return o;
@@ -2977,8 +3354,8 @@ buildStreamingConfigTask() {
 checkStreamingConfigTask(api.StreamingConfigTask o) {
   buildCounterStreamingConfigTask++;
   if (buildCounterStreamingConfigTask < 3) {
-    checkUnnamed3201(o.streamingComputationConfigs);
-    checkUnnamed3202(o.userStepToStateFamilyNameMap);
+    checkUnnamed3045(o.streamingComputationConfigs);
+    checkUnnamed3046(o.userStepToStateFamilyNameMap);
   }
   buildCounterStreamingConfigTask--;
 }
@@ -3048,14 +3425,14 @@ checkStreamingStageLocation(api.StreamingStageLocation o) {
   buildCounterStreamingStageLocation--;
 }
 
-buildUnnamed3203() {
+buildUnnamed3047() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3203(core.List<core.String> o) {
+checkUnnamed3047(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'));
@@ -3066,7 +3443,7 @@ buildStringList() {
   var o = new api.StringList();
   buildCounterStringList++;
   if (buildCounterStringList < 3) {
-    o.elements = buildUnnamed3203();
+    o.elements = buildUnnamed3047();
   }
   buildCounterStringList--;
   return o;
@@ -3075,19 +3452,19 @@ buildStringList() {
 checkStringList(api.StringList o) {
   buildCounterStringList++;
   if (buildCounterStringList < 3) {
-    checkUnnamed3203(o.elements);
+    checkUnnamed3047(o.elements);
   }
   buildCounterStringList--;
 }
 
-buildUnnamed3204() {
+buildUnnamed3048() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed3204(core.List<core.String> o) {
+checkUnnamed3048(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'));
@@ -3109,7 +3486,7 @@ buildTaskRunnerSettings() {
     o.logDir = "foo";
     o.logToSerialconsole = true;
     o.logUploadLocation = "foo";
-    o.oauthScopes = buildUnnamed3204();
+    o.oauthScopes = buildUnnamed3048();
     o.parallelWorkerSettings = buildWorkerSettings();
     o.streamingWorkerMainClass = "foo";
     o.taskGroup = "foo";
@@ -3136,7 +3513,7 @@ checkTaskRunnerSettings(api.TaskRunnerSettings o) {
     unittest.expect(o.logDir, unittest.equals('foo'));
     unittest.expect(o.logToSerialconsole, unittest.isTrue);
     unittest.expect(o.logUploadLocation, unittest.equals('foo'));
-    checkUnnamed3204(o.oauthScopes);
+    checkUnnamed3048(o.oauthScopes);
     checkWorkerSettings(o.parallelWorkerSettings);
     unittest.expect(o.streamingWorkerMainClass, unittest.equals('foo'));
     unittest.expect(o.taskGroup, unittest.equals('foo'));
@@ -3148,40 +3525,78 @@ checkTaskRunnerSettings(api.TaskRunnerSettings o) {
   buildCounterTaskRunnerSettings--;
 }
 
-buildUnnamed3205() {
+buildUnnamed3049() {
+  var o = new core.List<api.ParameterMetadata>();
+  o.add(buildParameterMetadata());
+  o.add(buildParameterMetadata());
+  return o;
+}
+
+checkUnnamed3049(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 = buildUnnamed3049();
+  }
+  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'));
+    checkUnnamed3049(o.parameters);
+  }
+  buildCounterTemplateMetadata--;
+}
+
+buildUnnamed3050() {
   var o = new core.List<api.ComputationTopology>();
   o.add(buildComputationTopology());
   o.add(buildComputationTopology());
   return o;
 }
 
-checkUnnamed3205(core.List<api.ComputationTopology> o) {
+checkUnnamed3050(core.List<api.ComputationTopology> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkComputationTopology(o[0]);
   checkComputationTopology(o[1]);
 }
 
-buildUnnamed3206() {
+buildUnnamed3051() {
   var o = new core.List<api.DataDiskAssignment>();
   o.add(buildDataDiskAssignment());
   o.add(buildDataDiskAssignment());
   return o;
 }
 
-checkUnnamed3206(core.List<api.DataDiskAssignment> o) {
+checkUnnamed3051(core.List<api.DataDiskAssignment> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkDataDiskAssignment(o[0]);
   checkDataDiskAssignment(o[1]);
 }
 
-buildUnnamed3207() {
+buildUnnamed3052() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3207(core.Map<core.String, core.String> o) {
+checkUnnamed3052(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'));
@@ -3192,11 +3607,11 @@ buildTopologyConfig() {
   var o = new api.TopologyConfig();
   buildCounterTopologyConfig++;
   if (buildCounterTopologyConfig < 3) {
-    o.computations = buildUnnamed3205();
-    o.dataDiskAssignments = buildUnnamed3206();
+    o.computations = buildUnnamed3050();
+    o.dataDiskAssignments = buildUnnamed3051();
     o.forwardingKeyBits = 42;
     o.persistentStateVersion = 42;
-    o.userStageToComputationNameMap = buildUnnamed3207();
+    o.userStageToComputationNameMap = buildUnnamed3052();
   }
   buildCounterTopologyConfig--;
   return o;
@@ -3205,23 +3620,91 @@ buildTopologyConfig() {
 checkTopologyConfig(api.TopologyConfig o) {
   buildCounterTopologyConfig++;
   if (buildCounterTopologyConfig < 3) {
-    checkUnnamed3205(o.computations);
-    checkUnnamed3206(o.dataDiskAssignments);
+    checkUnnamed3050(o.computations);
+    checkUnnamed3051(o.dataDiskAssignments);
     unittest.expect(o.forwardingKeyBits, unittest.equals(42));
     unittest.expect(o.persistentStateVersion, unittest.equals(42));
-    checkUnnamed3207(o.userStageToComputationNameMap);
+    checkUnnamed3052(o.userStageToComputationNameMap);
   }
   buildCounterTopologyConfig--;
 }
 
-buildUnnamed3208() {
+buildUnnamed3053() {
+  var o = new core.List<api.DisplayData>();
+  o.add(buildDisplayData());
+  o.add(buildDisplayData());
+  return o;
+}
+
+checkUnnamed3053(core.List<api.DisplayData> o) {
+  unittest.expect(o, unittest.hasLength(2));
+  checkDisplayData(o[0]);
+  checkDisplayData(o[1]);
+}
+
+buildUnnamed3054() {
+  var o = new core.List<core.String>();
+  o.add("foo");
+  o.add("foo");
+  return o;
+}
+
+checkUnnamed3054(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'));
+}
+
+buildUnnamed3055() {
+  var o = new core.List<core.String>();
+  o.add("foo");
+  o.add("foo");
+  return o;
+}
+
+checkUnnamed3055(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 = buildUnnamed3053();
+    o.id = "foo";
+    o.inputCollectionName = buildUnnamed3054();
+    o.kind = "foo";
+    o.name = "foo";
+    o.outputCollectionName = buildUnnamed3055();
+  }
+  buildCounterTransformSummary--;
+  return o;
+}
+
+checkTransformSummary(api.TransformSummary o) {
+  buildCounterTransformSummary++;
+  if (buildCounterTransformSummary < 3) {
+    checkUnnamed3053(o.displayData);
+    unittest.expect(o.id, unittest.equals('foo'));
+    checkUnnamed3054(o.inputCollectionName);
+    unittest.expect(o.kind, unittest.equals('foo'));
+    unittest.expect(o.name, unittest.equals('foo'));
+    checkUnnamed3055(o.outputCollectionName);
+  }
+  buildCounterTransformSummary--;
+}
+
+buildUnnamed3056() {
   var o = new core.List<api.Package>();
   o.add(buildPackage());
   o.add(buildPackage());
   return o;
 }
 
-checkUnnamed3208(core.List<api.Package> o) {
+checkUnnamed3056(core.List<api.Package> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkPackage(o[0]);
   checkPackage(o[1]);
@@ -3238,7 +3721,7 @@ buildWorkItem() {
     o.jobId = "foo";
     o.leaseExpireTime = "foo";
     o.mapTask = buildMapTask();
-    o.packages = buildUnnamed3208();
+    o.packages = buildUnnamed3056();
     o.projectId = "foo";
     o.reportStatusInterval = "foo";
     o.seqMapTask = buildSeqMapTask();
@@ -3261,7 +3744,7 @@ checkWorkItem(api.WorkItem o) {
     unittest.expect(o.jobId, unittest.equals('foo'));
     unittest.expect(o.leaseExpireTime, unittest.equals('foo'));
     checkMapTask(o.mapTask);
-    checkUnnamed3208(o.packages);
+    checkUnnamed3056(o.packages);
     unittest.expect(o.projectId, unittest.equals('foo'));
     unittest.expect(o.reportStatusInterval, unittest.equals('foo'));
     checkSeqMapTask(o.seqMapTask);
@@ -3274,27 +3757,27 @@ checkWorkItem(api.WorkItem o) {
   buildCounterWorkItem--;
 }
 
-buildUnnamed3209() {
+buildUnnamed3057() {
   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;
 }
 
-checkUnnamed3209(core.Map<core.String, core.Object> o) {
+checkUnnamed3057(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')); 
 }
 
-buildUnnamed3210() {
+buildUnnamed3058() {
   var o = new core.List<api.MetricShortId>();
   o.add(buildMetricShortId());
   o.add(buildMetricShortId());
   return o;
 }
 
-checkUnnamed3210(core.List<api.MetricShortId> o) {
+checkUnnamed3058(core.List<api.MetricShortId> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkMetricShortId(o[0]);
   checkMetricShortId(o[1]);
@@ -3305,9 +3788,9 @@ buildWorkItemServiceState() {
   var o = new api.WorkItemServiceState();
   buildCounterWorkItemServiceState++;
   if (buildCounterWorkItemServiceState < 3) {
-    o.harnessData = buildUnnamed3209();
+    o.harnessData = buildUnnamed3057();
     o.leaseExpireTime = "foo";
-    o.metricShortId = buildUnnamed3210();
+    o.metricShortId = buildUnnamed3058();
     o.nextReportIndex = "foo";
     o.reportStatusInterval = "foo";
     o.splitRequest = buildApproximateSplitRequest();
@@ -3321,9 +3804,9 @@ buildWorkItemServiceState() {
 checkWorkItemServiceState(api.WorkItemServiceState o) {
   buildCounterWorkItemServiceState++;
   if (buildCounterWorkItemServiceState < 3) {
-    checkUnnamed3209(o.harnessData);
+    checkUnnamed3057(o.harnessData);
     unittest.expect(o.leaseExpireTime, unittest.equals('foo'));
-    checkUnnamed3210(o.metricShortId);
+    checkUnnamed3058(o.metricShortId);
     unittest.expect(o.nextReportIndex, unittest.equals('foo'));
     unittest.expect(o.reportStatusInterval, unittest.equals('foo'));
     checkApproximateSplitRequest(o.splitRequest);
@@ -3333,40 +3816,40 @@ checkWorkItemServiceState(api.WorkItemServiceState o) {
   buildCounterWorkItemServiceState--;
 }
 
-buildUnnamed3211() {
+buildUnnamed3059() {
   var o = new core.List<api.CounterUpdate>();
   o.add(buildCounterUpdate());
   o.add(buildCounterUpdate());
   return o;
 }
 
-checkUnnamed3211(core.List<api.CounterUpdate> o) {
+checkUnnamed3059(core.List<api.CounterUpdate> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkCounterUpdate(o[0]);
   checkCounterUpdate(o[1]);
 }
 
-buildUnnamed3212() {
+buildUnnamed3060() {
   var o = new core.List<api.Status>();
   o.add(buildStatus());
   o.add(buildStatus());
   return o;
 }
 
-checkUnnamed3212(core.List<api.Status> o) {
+checkUnnamed3060(core.List<api.Status> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkStatus(o[0]);
   checkStatus(o[1]);
 }
 
-buildUnnamed3213() {
+buildUnnamed3061() {
   var o = new core.List<api.MetricUpdate>();
   o.add(buildMetricUpdate());
   o.add(buildMetricUpdate());
   return o;
 }
 
-checkUnnamed3213(core.List<api.MetricUpdate> o) {
+checkUnnamed3061(core.List<api.MetricUpdate> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkMetricUpdate(o[0]);
   checkMetricUpdate(o[1]);
@@ -3378,10 +3861,10 @@ buildWorkItemStatus() {
   buildCounterWorkItemStatus++;
   if (buildCounterWorkItemStatus < 3) {
     o.completed = true;
-    o.counterUpdates = buildUnnamed3211();
+    o.counterUpdates = buildUnnamed3059();
     o.dynamicSourceSplit = buildDynamicSourceSplit();
-    o.errors = buildUnnamed3212();
-    o.metricUpdates = buildUnnamed3213();
+    o.errors = buildUnnamed3060();
+    o.metricUpdates = buildUnnamed3061();
     o.progress = buildApproximateProgress();
     o.reportIndex = "foo";
     o.reportedProgress = buildApproximateReportedProgress();
@@ -3399,10 +3882,10 @@ checkWorkItemStatus(api.WorkItemStatus o) {
   buildCounterWorkItemStatus++;
   if (buildCounterWorkItemStatus < 3) {
     unittest.expect(o.completed, unittest.isTrue);
-    checkUnnamed3211(o.counterUpdates);
+    checkUnnamed3059(o.counterUpdates);
     checkDynamicSourceSplit(o.dynamicSourceSplit);
-    checkUnnamed3212(o.errors);
-    checkUnnamed3213(o.metricUpdates);
+    checkUnnamed3060(o.errors);
+    checkUnnamed3061(o.metricUpdates);
     checkApproximateProgress(o.progress);
     unittest.expect(o.reportIndex, unittest.equals('foo'));
     checkApproximateReportedProgress(o.reportedProgress);
@@ -3415,30 +3898,30 @@ checkWorkItemStatus(api.WorkItemStatus o) {
   buildCounterWorkItemStatus--;
 }
 
-buildUnnamed3214() {
+buildUnnamed3062() {
   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;
 }
 
-checkUnnamed3214(core.Map<core.String, core.Object> o) {
+checkUnnamed3062(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')); 
 }
 
-buildUnnamed3215() {
+buildUnnamed3063() {
   var o = new core.List<core.Map<core.String, core.Object>>();
-  o.add(buildUnnamed3214());
-  o.add(buildUnnamed3214());
+  o.add(buildUnnamed3062());
+  o.add(buildUnnamed3062());
   return o;
 }
 
-checkUnnamed3215(core.List<core.Map<core.String, core.Object>> o) {
+checkUnnamed3063(core.List<core.Map<core.String, core.Object>> o) {
   unittest.expect(o, unittest.hasLength(2));
-  checkUnnamed3214(o[0]);
-  checkUnnamed3214(o[1]);
+  checkUnnamed3062(o[0]);
+  checkUnnamed3062(o[1]);
 }
 
 core.int buildCounterWorkerHealthReport = 0;
@@ -3446,7 +3929,7 @@ buildWorkerHealthReport() {
   var o = new api.WorkerHealthReport();
   buildCounterWorkerHealthReport++;
   if (buildCounterWorkerHealthReport < 3) {
-    o.pods = buildUnnamed3215();
+    o.pods = buildUnnamed3063();
     o.reportInterval = "foo";
     o.vmIsHealthy = true;
     o.vmStartupTime = "foo";
@@ -3458,7 +3941,7 @@ buildWorkerHealthReport() {
 checkWorkerHealthReport(api.WorkerHealthReport o) {
   buildCounterWorkerHealthReport++;
   if (buildCounterWorkerHealthReport < 3) {
-    checkUnnamed3215(o.pods);
+    checkUnnamed3063(o.pods);
     unittest.expect(o.reportInterval, unittest.equals('foo'));
     unittest.expect(o.vmIsHealthy, unittest.isTrue);
     unittest.expect(o.vmStartupTime, unittest.equals('foo'));
@@ -3485,14 +3968,14 @@ checkWorkerHealthReportResponse(api.WorkerHealthReportResponse o) {
   buildCounterWorkerHealthReportResponse--;
 }
 
-buildUnnamed3216() {
+buildUnnamed3064() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3216(core.Map<core.String, core.String> o) {
+checkUnnamed3064(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'));
@@ -3503,7 +3986,7 @@ buildWorkerMessage() {
   var o = new api.WorkerMessage();
   buildCounterWorkerMessage++;
   if (buildCounterWorkerMessage < 3) {
-    o.labels = buildUnnamed3216();
+    o.labels = buildUnnamed3064();
     o.time = "foo";
     o.workerHealthReport = buildWorkerHealthReport();
     o.workerMessageCode = buildWorkerMessageCode();
@@ -3516,7 +3999,7 @@ buildWorkerMessage() {
 checkWorkerMessage(api.WorkerMessage o) {
   buildCounterWorkerMessage++;
   if (buildCounterWorkerMessage < 3) {
-    checkUnnamed3216(o.labels);
+    checkUnnamed3064(o.labels);
     unittest.expect(o.time, unittest.equals('foo'));
     checkWorkerHealthReport(o.workerHealthReport);
     checkWorkerMessageCode(o.workerMessageCode);
@@ -3525,14 +4008,14 @@ checkWorkerMessage(api.WorkerMessage o) {
   buildCounterWorkerMessage--;
 }
 
-buildUnnamed3217() {
+buildUnnamed3065() {
   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;
 }
 
-checkUnnamed3217(core.Map<core.String, core.Object> o) {
+checkUnnamed3065(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')); 
@@ -3544,7 +4027,7 @@ buildWorkerMessageCode() {
   buildCounterWorkerMessageCode++;
   if (buildCounterWorkerMessageCode < 3) {
     o.code = "foo";
-    o.parameters = buildUnnamed3217();
+    o.parameters = buildUnnamed3065();
   }
   buildCounterWorkerMessageCode--;
   return o;
@@ -3554,7 +4037,7 @@ checkWorkerMessageCode(api.WorkerMessageCode o) {
   buildCounterWorkerMessageCode++;
   if (buildCounterWorkerMessageCode < 3) {
     unittest.expect(o.code, unittest.equals('foo'));
-    checkUnnamed3217(o.parameters);
+    checkUnnamed3065(o.parameters);
   }
   buildCounterWorkerMessageCode--;
 }
@@ -3580,53 +4063,53 @@ checkWorkerMessageResponse(api.WorkerMessageResponse o) {
   buildCounterWorkerMessageResponse--;
 }
 
-buildUnnamed3218() {
+buildUnnamed3066() {
   var o = new core.List<api.Disk>();
   o.add(buildDisk());
   o.add(buildDisk());
   return o;
 }
 
-checkUnnamed3218(core.List<api.Disk> o) {
+checkUnnamed3066(core.List<api.Disk> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkDisk(o[0]);
   checkDisk(o[1]);
 }
 
-buildUnnamed3219() {
+buildUnnamed3067() {
   var o = new core.Map<core.String, core.String>();
   o["x"] = "foo";
   o["y"] = "foo";
   return o;
 }
 
-checkUnnamed3219(core.Map<core.String, core.String> o) {
+checkUnnamed3067(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'));
 }
 
-buildUnnamed3220() {
+buildUnnamed3068() {
   var o = new core.List<api.Package>();
   o.add(buildPackage());
   o.add(buildPackage());
   return o;
 }
 
-checkUnnamed3220(core.List<api.Package> o) {
+checkUnnamed3068(core.List<api.Package> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkPackage(o[0]);
   checkPackage(o[1]);
 }
 
-buildUnnamed3221() {
+buildUnnamed3069() {
   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;
 }
 
-checkUnnamed3221(core.Map<core.String, core.Object> o) {
+checkUnnamed3069(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')); 
@@ -3638,7 +4121,7 @@ buildWorkerPool() {
   buildCounterWorkerPool++;
   if (buildCounterWorkerPool < 3) {
     o.autoscalingSettings = buildAutoscalingSettings();
-    o.dataDisks = buildUnnamed3218();
+    o.dataDisks = buildUnnamed3066();
     o.defaultPackageSet = "foo";
     o.diskSizeGb = 42;
     o.diskSourceImage = "foo";
@@ -3646,13 +4129,13 @@ buildWorkerPool() {
     o.ipConfiguration = "foo";
     o.kind = "foo";
     o.machineType = "foo";
-    o.metadata = buildUnnamed3219();
+    o.metadata = buildUnnamed3067();
     o.network = "foo";
     o.numThreadsPerWorker = 42;
     o.numWorkers = 42;
     o.onHostMaintenance = "foo";
-    o.packages = buildUnnamed3220();
-    o.poolArgs = buildUnnamed3221();
+    o.packages = buildUnnamed3068();
+    o.poolArgs = buildUnnamed3069();
     o.subnetwork = "foo";
     o.taskrunnerSettings = buildTaskRunnerSettings();
     o.teardownPolicy = "foo";
@@ -3667,7 +4150,7 @@ checkWorkerPool(api.WorkerPool o) {
   buildCounterWorkerPool++;
   if (buildCounterWorkerPool < 3) {
     checkAutoscalingSettings(o.autoscalingSettings);
-    checkUnnamed3218(o.dataDisks);
+    checkUnnamed3066(o.dataDisks);
     unittest.expect(o.defaultPackageSet, unittest.equals('foo'));
     unittest.expect(o.diskSizeGb, unittest.equals(42));
     unittest.expect(o.diskSourceImage, unittest.equals('foo'));
@@ -3675,13 +4158,13 @@ checkWorkerPool(api.WorkerPool o) {
     unittest.expect(o.ipConfiguration, unittest.equals('foo'));
     unittest.expect(o.kind, unittest.equals('foo'));
     unittest.expect(o.machineType, unittest.equals('foo'));
-    checkUnnamed3219(o.metadata);
+    checkUnnamed3067(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'));
-    checkUnnamed3220(o.packages);
-    checkUnnamed3221(o.poolArgs);
+    checkUnnamed3068(o.packages);
+    checkUnnamed3069(o.poolArgs);
     unittest.expect(o.subnetwork, unittest.equals('foo'));
     checkTaskRunnerSettings(o.taskrunnerSettings);
     unittest.expect(o.teardownPolicy, unittest.equals('foo'));
@@ -3788,6 +4271,24 @@ main() {
   });
 
 
+  unittest.group("obj-schema-ComponentSource", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildComponentSource();
+      var od = new api.ComponentSource.fromJson(o.toJson());
+      checkComponentSource(od);
+    });
+  });
+
+
+  unittest.group("obj-schema-ComponentTransform", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildComponentTransform();
+      var od = new api.ComponentTransform.fromJson(o.toJson());
+      checkComponentTransform(od);
+    });
+  });
+
+
   unittest.group("obj-schema-ComputationTopology", () {
     unittest.test("to-json--from-json", () {
       var o = buildComputationTopology();
@@ -3887,6 +4388,15 @@ main() {
   });
 
 
+  unittest.group("obj-schema-DisplayData", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildDisplayData();
+      var od = new api.DisplayData.fromJson(o.toJson());
+      checkDisplayData(od);
+    });
+  });
+
+
   unittest.group("obj-schema-DistributionUpdate", () {
     unittest.test("to-json--from-json", () {
       var o = buildDistributionUpdate();
@@ -3914,6 +4424,15 @@ main() {
   });
 
 
+  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", () {
     unittest.test("to-json--from-json", () {
       var o = buildFailedLocation();
@@ -3968,6 +4487,15 @@ main() {
   });
 
 
+  unittest.group("obj-schema-GetTemplateResponse", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildGetTemplateResponse();
+      var od = new api.GetTemplateResponse.fromJson(o.toJson());
+      checkGetTemplateResponse(od);
+    });
+  });
+
+
   unittest.group("obj-schema-InstructionInput", () {
     unittest.test("to-json--from-json", () {
       var o = buildInstructionInput();
@@ -4067,6 +4595,24 @@ main() {
   });
 
 
+  unittest.group("obj-schema-LaunchTemplateParameters", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildLaunchTemplateParameters();
+      var od = new api.LaunchTemplateParameters.fromJson(o.toJson());
+      checkLaunchTemplateParameters(od);
+    });
+  });
+
+
+  unittest.group("obj-schema-LaunchTemplateResponse", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildLaunchTemplateResponse();
+      var od = new api.LaunchTemplateResponse.fromJson(o.toJson());
+      checkLaunchTemplateResponse(od);
+    });
+  });
+
+
   unittest.group("obj-schema-LeaseWorkItemRequest", () {
     unittest.test("to-json--from-json", () {
       var o = buildLeaseWorkItemRequest();
@@ -4193,6 +4739,15 @@ main() {
   });
 
 
+  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", () {
     unittest.test("to-json--from-json", () {
       var o = buildPartialGroupByKeyInstruction();
@@ -4202,6 +4757,15 @@ main() {
   });
 
 
+  unittest.group("obj-schema-PipelineDescription", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildPipelineDescription();
+      var od = new api.PipelineDescription.fromJson(o.toJson());
+      checkPipelineDescription(od);
+    });
+  });
+
+
   unittest.group("obj-schema-Position", () {
     unittest.test("to-json--from-json", () {
       var o = buildPosition();
@@ -4472,6 +5036,15 @@ main() {
   });
 
 
+  unittest.group("obj-schema-StageSource", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildStageSource();
+      var od = new api.StageSource.fromJson(o.toJson());
+      checkStageSource(od);
+    });
+  });
+
+
   unittest.group("obj-schema-StateFamilyConfig", () {
     unittest.test("to-json--from-json", () {
       var o = buildStateFamilyConfig();
@@ -4589,6 +5162,15 @@ main() {
   });
 
 
+  unittest.group("obj-schema-TemplateMetadata", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildTemplateMetadata();
+      var od = new api.TemplateMetadata.fromJson(o.toJson());
+      checkTemplateMetadata(od);
+    });
+  });
+
+
   unittest.group("obj-schema-TopologyConfig", () {
     unittest.test("to-json--from-json", () {
       var o = buildTopologyConfig();
@@ -4598,6 +5180,15 @@ main() {
   });
 
 
+  unittest.group("obj-schema-TransformSummary", () {
+    unittest.test("to-json--from-json", () {
+      var o = buildTransformSummary();
+      var od = new api.TransformSummary.fromJson(o.toJson());
+      checkTransformSummary(od);
+    });
+  });
+
+
   unittest.group("obj-schema-WorkItem", () {
     unittest.test("to-json--from-json", () {
       var o = buildWorkItem();
@@ -4824,8 +5415,8 @@ main() {
       api.ProjectsJobsResourceApi res = new api.DataflowApi(mock).projects.jobs;
       var arg_projectId = "foo";
       var arg_jobId = "foo";
-      var arg_view = "foo";
       var arg_location = "foo";
+      var arg_view = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
@@ -4862,8 +5453,8 @@ main() {
             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["view"].first, unittest.equals(arg_view));
 
 
         var h = {
@@ -4872,7 +5463,7 @@ main() {
         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);
       })));
     });
@@ -5202,12 +5793,12 @@ main() {
       api.ProjectsJobsMessagesResourceApi res = new api.DataflowApi(mock).projects.jobs.messages;
       var arg_projectId = "foo";
       var arg_jobId = "foo";
-      var arg_minimumImportance = "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_location = "foo";
+      var arg_endTime = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
@@ -5248,12 +5839,12 @@ main() {
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
-        unittest.expect(queryMap["minimumImportance"].first, unittest.equals(arg_minimumImportance));
-        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["location"].first, unittest.equals(arg_location));
+        unittest.expect(queryMap["endTime"].first, unittest.equals(arg_endTime));
 
 
         var h = {
@@ -5262,7 +5853,7 @@ main() {
         var resp = convert.JSON.encode(buildListJobMessagesResponse());
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
-      res.list(arg_projectId, arg_jobId, minimumImportance: arg_minimumImportance, location: arg_location, endTime: arg_endTime, startTime: arg_startTime, pageToken: arg_pageToken, pageSize: arg_pageSize).then(unittest.expectAsync(((api.ListJobMessagesResponse response) {
+      res.list(arg_projectId, arg_jobId, startTime: arg_startTime, pageToken: arg_pageToken, pageSize: arg_pageSize, minimumImportance: arg_minimumImportance, location: arg_location, endTime: arg_endTime).then(unittest.expectAsync(((api.ListJobMessagesResponse response) {
         checkListJobMessagesResponse(response);
       })));
     });
@@ -5408,8 +5999,8 @@ main() {
       var arg_request = buildJob();
       var arg_projectId = "foo";
       var arg_location = "foo";
-      var arg_view = "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);
@@ -5453,8 +6044,8 @@ main() {
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
-        unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
         unittest.expect(queryMap["replaceJobId"].first, unittest.equals(arg_replaceJobId));
+        unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
 
 
         var h = {
@@ -5463,7 +6054,7 @@ main() {
         var resp = convert.JSON.encode(buildJob());
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
-      res.create(arg_request, arg_projectId, arg_location, view: arg_view, replaceJobId: arg_replaceJobId).then(unittest.expectAsync(((api.Job response) {
+      res.create(arg_request, arg_projectId, arg_location, replaceJobId: arg_replaceJobId, view: arg_view).then(unittest.expectAsync(((api.Job response) {
         checkJob(response);
       })));
     });
@@ -5748,8 +6339,8 @@ main() {
       var arg_location = "foo";
       var arg_jobId = "foo";
       var arg_endTime = "foo";
-      var arg_startTime = "foo";
       var arg_pageToken = "foo";
+      var arg_startTime = "foo";
       var arg_pageSize = 42;
       var arg_minimumImportance = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
@@ -5800,8 +6391,8 @@ main() {
           }
         }
         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(queryMap["startTime"].first, unittest.equals(arg_startTime));
         unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
         unittest.expect(queryMap["minimumImportance"].first, unittest.equals(arg_minimumImportance));
 
@@ -5812,7 +6403,7 @@ main() {
         var resp = convert.JSON.encode(buildListJobMessagesResponse());
         return new async.Future.value(stringResponse(200, h, resp));
       }), true);
-      res.list(arg_projectId, arg_location, arg_jobId, endTime: arg_endTime, startTime: arg_startTime, pageToken: arg_pageToken, pageSize: arg_pageSize, minimumImportance: arg_minimumImportance).then(unittest.expectAsync(((api.ListJobMessagesResponse response) {
+      res.list(arg_projectId, arg_location, arg_jobId, endTime: arg_endTime, pageToken: arg_pageToken, startTime: arg_startTime, pageSize: arg_pageSize, minimumImportance: arg_minimumImportance).then(unittest.expectAsync(((api.ListJobMessagesResponse response) {
         checkListJobMessagesResponse(response);
       })));
     });
@@ -6022,6 +6613,120 @@ main() {
       })));
     });
 
+    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";
+      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);
+        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 + 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, view: arg_view, gcsPath: arg_gcsPath).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_dryRun = true;
+      var arg_gcsPath = "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;
+        unittest.expect(path.substring(pathOffset, pathOffset + 14), unittest.equals("v1b3/projects/"));
+        pathOffset += 14;
+        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_projectId"));
+        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["dryRun"].first, unittest.equals("$arg_dryRun"));
+        unittest.expect(queryMap["gcsPath"].first, unittest.equals(arg_gcsPath));
+
+
+        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, dryRun: arg_dryRun, gcsPath: arg_gcsPath).then(unittest.expectAsync(((api.LaunchTemplateResponse response) {
+        checkLaunchTemplateResponse(response);
+      })));
+    });
+
   });