Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(3)

Unified Diff: generated/googleapis_beta/test/dataflow/v1b3_test.dart

Issue 2936613002: Api-Roll 50: 2017-06-12 (Closed)
Patch Set: Created 3 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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 606619ffa8f07cf25f3c75d43af31c53ec174840..0d117daae362087bcdf6c533ae860a75addbffe7 100644
--- a/generated/googleapis_beta/test/dataflow/v1b3_test.dart
+++ b/generated/googleapis_beta/test/dataflow/v1b3_test.dart
@@ -7,7 +7,7 @@ import "dart:convert" as convert;
import 'package:http/http.dart' as http;
import 'package:http/testing.dart' as http_testing;
-import 'package:unittest/unittest.dart' as unittest;
+import 'package:test/test.dart' as unittest;
import 'package:googleapis_beta/dataflow/v1b3.dart' as api;
@@ -46,7 +46,7 @@ class HttpServerMock extends http.BaseClient {
}
http.StreamedResponse stringResponse(
- core.int status, core.Map headers, core.String body) {
+ core.int status, core.Map<core.String, core.String> headers, core.String body) {
var stream = new async.Stream.fromIterable([convert.UTF8.encode(body)]);
return new http.StreamedResponse(stream, status, headers: headers);
}
@@ -237,53 +237,53 @@ checkComponentTransform(api.ComponentTransform o) {
buildCounterComponentTransform--;
}
-buildUnnamed3447() {
+buildUnnamed2921() {
var o = new core.List<api.StreamLocation>();
o.add(buildStreamLocation());
o.add(buildStreamLocation());
return o;
}
-checkUnnamed3447(core.List<api.StreamLocation> o) {
+checkUnnamed2921(core.List<api.StreamLocation> o) {
unittest.expect(o, unittest.hasLength(2));
checkStreamLocation(o[0]);
checkStreamLocation(o[1]);
}
-buildUnnamed3448() {
+buildUnnamed2922() {
var o = new core.List<api.KeyRangeLocation>();
o.add(buildKeyRangeLocation());
o.add(buildKeyRangeLocation());
return o;
}
-checkUnnamed3448(core.List<api.KeyRangeLocation> o) {
+checkUnnamed2922(core.List<api.KeyRangeLocation> o) {
unittest.expect(o, unittest.hasLength(2));
checkKeyRangeLocation(o[0]);
checkKeyRangeLocation(o[1]);
}
-buildUnnamed3449() {
+buildUnnamed2923() {
var o = new core.List<api.StreamLocation>();
o.add(buildStreamLocation());
o.add(buildStreamLocation());
return o;
}
-checkUnnamed3449(core.List<api.StreamLocation> o) {
+checkUnnamed2923(core.List<api.StreamLocation> o) {
unittest.expect(o, unittest.hasLength(2));
checkStreamLocation(o[0]);
checkStreamLocation(o[1]);
}
-buildUnnamed3450() {
+buildUnnamed2924() {
var o = new core.List<api.StateFamilyConfig>();
o.add(buildStateFamilyConfig());
o.add(buildStateFamilyConfig());
return o;
}
-checkUnnamed3450(core.List<api.StateFamilyConfig> o) {
+checkUnnamed2924(core.List<api.StateFamilyConfig> o) {
unittest.expect(o, unittest.hasLength(2));
checkStateFamilyConfig(o[0]);
checkStateFamilyConfig(o[1]);
@@ -295,10 +295,10 @@ buildComputationTopology() {
buildCounterComputationTopology++;
if (buildCounterComputationTopology < 3) {
o.computationId = "foo";
- o.inputs = buildUnnamed3447();
- o.keyRanges = buildUnnamed3448();
- o.outputs = buildUnnamed3449();
- o.stateFamilies = buildUnnamed3450();
+ o.inputs = buildUnnamed2921();
+ o.keyRanges = buildUnnamed2922();
+ o.outputs = buildUnnamed2923();
+ o.stateFamilies = buildUnnamed2924();
o.systemStageName = "foo";
}
buildCounterComputationTopology--;
@@ -309,10 +309,10 @@ checkComputationTopology(api.ComputationTopology o) {
buildCounterComputationTopology++;
if (buildCounterComputationTopology < 3) {
unittest.expect(o.computationId, unittest.equals('foo'));
- checkUnnamed3447(o.inputs);
- checkUnnamed3448(o.keyRanges);
- checkUnnamed3449(o.outputs);
- checkUnnamed3450(o.stateFamilies);
+ checkUnnamed2921(o.inputs);
+ checkUnnamed2922(o.keyRanges);
+ checkUnnamed2923(o.outputs);
+ checkUnnamed2924(o.stateFamilies);
unittest.expect(o.systemStageName, unittest.equals('foo'));
}
buildCounterComputationTopology--;
@@ -463,14 +463,14 @@ checkCounterUpdate(api.CounterUpdate o) {
buildCounterCounterUpdate--;
}
-buildUnnamed3451() {
+buildUnnamed2925() {
var o = new core.Map<core.String, core.String>();
o["x"] = "foo";
o["y"] = "foo";
return o;
}
-checkUnnamed3451(core.Map<core.String, core.String> o) {
+checkUnnamed2925(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'));
@@ -485,7 +485,7 @@ buildCreateJobFromTemplateRequest() {
o.gcsPath = "foo";
o.jobName = "foo";
o.location = "foo";
- o.parameters = buildUnnamed3451();
+ o.parameters = buildUnnamed2925();
}
buildCounterCreateJobFromTemplateRequest--;
return o;
@@ -498,7 +498,7 @@ checkCreateJobFromTemplateRequest(api.CreateJobFromTemplateRequest o) {
unittest.expect(o.gcsPath, unittest.equals('foo'));
unittest.expect(o.jobName, unittest.equals('foo'));
unittest.expect(o.location, unittest.equals('foo'));
- checkUnnamed3451(o.parameters);
+ checkUnnamed2925(o.parameters);
}
buildCounterCreateJobFromTemplateRequest--;
}
@@ -522,14 +522,14 @@ checkCustomSourceLocation(api.CustomSourceLocation o) {
buildCounterCustomSourceLocation--;
}
-buildUnnamed3452() {
+buildUnnamed2926() {
var o = new core.List<core.String>();
o.add("foo");
o.add("foo");
return o;
}
-checkUnnamed3452(core.List<core.String> o) {
+checkUnnamed2926(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'));
@@ -540,7 +540,7 @@ buildDataDiskAssignment() {
var o = new api.DataDiskAssignment();
buildCounterDataDiskAssignment++;
if (buildCounterDataDiskAssignment < 3) {
- o.dataDisks = buildUnnamed3452();
+ o.dataDisks = buildUnnamed2926();
o.vmInstance = "foo";
}
buildCounterDataDiskAssignment--;
@@ -550,7 +550,7 @@ buildDataDiskAssignment() {
checkDataDiskAssignment(api.DataDiskAssignment o) {
buildCounterDataDiskAssignment++;
if (buildCounterDataDiskAssignment < 3) {
- checkUnnamed3452(o.dataDisks);
+ checkUnnamed2926(o.dataDisks);
unittest.expect(o.vmInstance, unittest.equals('foo'));
}
buildCounterDataDiskAssignment--;
@@ -641,14 +641,14 @@ checkDisplayData(api.DisplayData o) {
buildCounterDisplayData--;
}
-buildUnnamed3453() {
+buildUnnamed2927() {
var o = new core.List<api.LogBucket>();
o.add(buildLogBucket());
o.add(buildLogBucket());
return o;
}
-checkUnnamed3453(core.List<api.LogBucket> o) {
+checkUnnamed2927(core.List<api.LogBucket> o) {
unittest.expect(o, unittest.hasLength(2));
checkLogBucket(o[0]);
checkLogBucket(o[1]);
@@ -660,7 +660,7 @@ buildDistributionUpdate() {
buildCounterDistributionUpdate++;
if (buildCounterDistributionUpdate < 3) {
o.count = buildSplitInt64();
- o.logBuckets = buildUnnamed3453();
+ o.logBuckets = buildUnnamed2927();
o.max = buildSplitInt64();
o.min = buildSplitInt64();
o.sum = buildSplitInt64();
@@ -674,7 +674,7 @@ checkDistributionUpdate(api.DistributionUpdate o) {
buildCounterDistributionUpdate++;
if (buildCounterDistributionUpdate < 3) {
checkSplitInt64(o.count);
- checkUnnamed3453(o.logBuckets);
+ checkUnnamed2927(o.logBuckets);
checkSplitInt64(o.max);
checkSplitInt64(o.min);
checkSplitInt64(o.sum);
@@ -704,79 +704,79 @@ checkDynamicSourceSplit(api.DynamicSourceSplit o) {
buildCounterDynamicSourceSplit--;
}
-buildUnnamed3454() {
+buildUnnamed2928() {
var o = new core.List<core.String>();
o.add("foo");
o.add("foo");
return o;
}
-checkUnnamed3454(core.List<core.String> o) {
+checkUnnamed2928(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'));
}
-buildUnnamed3455() {
+buildUnnamed2929() {
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;
}
-checkUnnamed3455(core.Map<core.String, core.Object> o) {
+checkUnnamed2929(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'));
}
-buildUnnamed3456() {
+buildUnnamed2930() {
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;
}
-checkUnnamed3456(core.Map<core.String, core.Object> o) {
+checkUnnamed2930(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'));
}
-buildUnnamed3457() {
+buildUnnamed2931() {
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;
}
-checkUnnamed3457(core.Map<core.String, core.Object> o) {
+checkUnnamed2931(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'));
}
-buildUnnamed3458() {
+buildUnnamed2932() {
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;
}
-checkUnnamed3458(core.Map<core.String, core.Object> o) {
+checkUnnamed2932(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'));
}
-buildUnnamed3459() {
+buildUnnamed2933() {
var o = new core.List<api.WorkerPool>();
o.add(buildWorkerPool());
o.add(buildWorkerPool());
return o;
}
-checkUnnamed3459(core.List<api.WorkerPool> o) {
+checkUnnamed2933(core.List<api.WorkerPool> o) {
unittest.expect(o, unittest.hasLength(2));
checkWorkerPool(o[0]);
checkWorkerPool(o[1]);
@@ -789,14 +789,14 @@ buildEnvironment() {
if (buildCounterEnvironment < 3) {
o.clusterManagerApiService = "foo";
o.dataset = "foo";
- o.experiments = buildUnnamed3454();
- o.internalExperiments = buildUnnamed3455();
- o.sdkPipelineOptions = buildUnnamed3456();
+ o.experiments = buildUnnamed2928();
+ o.internalExperiments = buildUnnamed2929();
+ o.sdkPipelineOptions = buildUnnamed2930();
o.serviceAccountEmail = "foo";
o.tempStoragePrefix = "foo";
- o.userAgent = buildUnnamed3457();
- o.version = buildUnnamed3458();
- o.workerPools = buildUnnamed3459();
+ o.userAgent = buildUnnamed2931();
+ o.version = buildUnnamed2932();
+ o.workerPools = buildUnnamed2933();
}
buildCounterEnvironment--;
return o;
@@ -807,14 +807,14 @@ checkEnvironment(api.Environment o) {
if (buildCounterEnvironment < 3) {
unittest.expect(o.clusterManagerApiService, unittest.equals('foo'));
unittest.expect(o.dataset, unittest.equals('foo'));
- checkUnnamed3454(o.experiments);
- checkUnnamed3455(o.internalExperiments);
- checkUnnamed3456(o.sdkPipelineOptions);
+ checkUnnamed2928(o.experiments);
+ checkUnnamed2929(o.internalExperiments);
+ checkUnnamed2930(o.sdkPipelineOptions);
unittest.expect(o.serviceAccountEmail, unittest.equals('foo'));
unittest.expect(o.tempStoragePrefix, unittest.equals('foo'));
- checkUnnamed3457(o.userAgent);
- checkUnnamed3458(o.version);
- checkUnnamed3459(o.workerPools);
+ checkUnnamed2931(o.userAgent);
+ checkUnnamed2932(o.version);
+ checkUnnamed2933(o.workerPools);
}
buildCounterEnvironment--;
}
@@ -842,53 +842,53 @@ checkExecutionStageState(api.ExecutionStageState o) {
buildCounterExecutionStageState--;
}
-buildUnnamed3460() {
+buildUnnamed2934() {
var o = new core.List<api.ComponentSource>();
o.add(buildComponentSource());
o.add(buildComponentSource());
return o;
}
-checkUnnamed3460(core.List<api.ComponentSource> o) {
+checkUnnamed2934(core.List<api.ComponentSource> o) {
unittest.expect(o, unittest.hasLength(2));
checkComponentSource(o[0]);
checkComponentSource(o[1]);
}
-buildUnnamed3461() {
+buildUnnamed2935() {
var o = new core.List<api.ComponentTransform>();
o.add(buildComponentTransform());
o.add(buildComponentTransform());
return o;
}
-checkUnnamed3461(core.List<api.ComponentTransform> o) {
+checkUnnamed2935(core.List<api.ComponentTransform> o) {
unittest.expect(o, unittest.hasLength(2));
checkComponentTransform(o[0]);
checkComponentTransform(o[1]);
}
-buildUnnamed3462() {
+buildUnnamed2936() {
var o = new core.List<api.StageSource>();
o.add(buildStageSource());
o.add(buildStageSource());
return o;
}
-checkUnnamed3462(core.List<api.StageSource> o) {
+checkUnnamed2936(core.List<api.StageSource> o) {
unittest.expect(o, unittest.hasLength(2));
checkStageSource(o[0]);
checkStageSource(o[1]);
}
-buildUnnamed3463() {
+buildUnnamed2937() {
var o = new core.List<api.StageSource>();
o.add(buildStageSource());
o.add(buildStageSource());
return o;
}
-checkUnnamed3463(core.List<api.StageSource> o) {
+checkUnnamed2937(core.List<api.StageSource> o) {
unittest.expect(o, unittest.hasLength(2));
checkStageSource(o[0]);
checkStageSource(o[1]);
@@ -899,13 +899,13 @@ buildExecutionStageSummary() {
var o = new api.ExecutionStageSummary();
buildCounterExecutionStageSummary++;
if (buildCounterExecutionStageSummary < 3) {
- o.componentSource = buildUnnamed3460();
- o.componentTransform = buildUnnamed3461();
+ o.componentSource = buildUnnamed2934();
+ o.componentTransform = buildUnnamed2935();
o.id = "foo";
- o.inputSource = buildUnnamed3462();
+ o.inputSource = buildUnnamed2936();
o.kind = "foo";
o.name = "foo";
- o.outputSource = buildUnnamed3463();
+ o.outputSource = buildUnnamed2937();
}
buildCounterExecutionStageSummary--;
return o;
@@ -914,13 +914,13 @@ buildExecutionStageSummary() {
checkExecutionStageSummary(api.ExecutionStageSummary o) {
buildCounterExecutionStageSummary++;
if (buildCounterExecutionStageSummary < 3) {
- checkUnnamed3460(o.componentSource);
- checkUnnamed3461(o.componentTransform);
+ checkUnnamed2934(o.componentSource);
+ checkUnnamed2935(o.componentTransform);
unittest.expect(o.id, unittest.equals('foo'));
- checkUnnamed3462(o.inputSource);
+ checkUnnamed2936(o.inputSource);
unittest.expect(o.kind, unittest.equals('foo'));
unittest.expect(o.name, unittest.equals('foo'));
- checkUnnamed3463(o.outputSource);
+ checkUnnamed2937(o.outputSource);
}
buildCounterExecutionStageSummary--;
}
@@ -944,14 +944,14 @@ checkFailedLocation(api.FailedLocation o) {
buildCounterFailedLocation--;
}
-buildUnnamed3464() {
+buildUnnamed2938() {
var o = new core.List<api.InstructionInput>();
o.add(buildInstructionInput());
o.add(buildInstructionInput());
return o;
}
-checkUnnamed3464(core.List<api.InstructionInput> o) {
+checkUnnamed2938(core.List<api.InstructionInput> o) {
unittest.expect(o, unittest.hasLength(2));
checkInstructionInput(o[0]);
checkInstructionInput(o[1]);
@@ -962,7 +962,7 @@ buildFlattenInstruction() {
var o = new api.FlattenInstruction();
buildCounterFlattenInstruction++;
if (buildCounterFlattenInstruction < 3) {
- o.inputs = buildUnnamed3464();
+ o.inputs = buildUnnamed2938();
}
buildCounterFlattenInstruction--;
return o;
@@ -971,19 +971,19 @@ buildFlattenInstruction() {
checkFlattenInstruction(api.FlattenInstruction o) {
buildCounterFlattenInstruction++;
if (buildCounterFlattenInstruction < 3) {
- checkUnnamed3464(o.inputs);
+ checkUnnamed2938(o.inputs);
}
buildCounterFlattenInstruction--;
}
-buildUnnamed3465() {
+buildUnnamed2939() {
var o = new core.List<core.double>();
o.add(42.0);
o.add(42.0);
return o;
}
-checkUnnamed3465(core.List<core.double> o) {
+checkUnnamed2939(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));
@@ -994,7 +994,7 @@ buildFloatingPointList() {
var o = new api.FloatingPointList();
buildCounterFloatingPointList++;
if (buildCounterFloatingPointList < 3) {
- o.elements = buildUnnamed3465();
+ o.elements = buildUnnamed2939();
}
buildCounterFloatingPointList--;
return o;
@@ -1003,7 +1003,7 @@ buildFloatingPointList() {
checkFloatingPointList(api.FloatingPointList o) {
buildCounterFloatingPointList++;
if (buildCounterFloatingPointList < 3) {
- checkUnnamed3465(o.elements);
+ checkUnnamed2939(o.elements);
}
buildCounterFloatingPointList--;
}
@@ -1113,14 +1113,14 @@ checkInstructionInput(api.InstructionInput o) {
buildCounterInstructionInput--;
}
-buildUnnamed3466() {
+buildUnnamed2940() {
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;
}
-checkUnnamed3466(core.Map<core.String, core.Object> o) {
+checkUnnamed2940(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'));
@@ -1131,7 +1131,7 @@ buildInstructionOutput() {
var o = new api.InstructionOutput();
buildCounterInstructionOutput++;
if (buildCounterInstructionOutput < 3) {
- o.codec = buildUnnamed3466();
+ o.codec = buildUnnamed2940();
o.name = "foo";
o.onlyCountKeyBytes = true;
o.onlyCountValueBytes = true;
@@ -1145,7 +1145,7 @@ buildInstructionOutput() {
checkInstructionOutput(api.InstructionOutput o) {
buildCounterInstructionOutput++;
if (buildCounterInstructionOutput < 3) {
- checkUnnamed3466(o.codec);
+ checkUnnamed2940(o.codec);
unittest.expect(o.name, unittest.equals('foo'));
unittest.expect(o.onlyCountKeyBytes, unittest.isTrue);
unittest.expect(o.onlyCountValueBytes, unittest.isTrue);
@@ -1155,14 +1155,14 @@ checkInstructionOutput(api.InstructionOutput o) {
buildCounterInstructionOutput--;
}
-buildUnnamed3467() {
+buildUnnamed2941() {
var o = new core.List<api.SplitInt64>();
o.add(buildSplitInt64());
o.add(buildSplitInt64());
return o;
}
-checkUnnamed3467(core.List<api.SplitInt64> o) {
+checkUnnamed2941(core.List<api.SplitInt64> o) {
unittest.expect(o, unittest.hasLength(2));
checkSplitInt64(o[0]);
checkSplitInt64(o[1]);
@@ -1173,7 +1173,7 @@ buildIntegerList() {
var o = new api.IntegerList();
buildCounterIntegerList++;
if (buildCounterIntegerList < 3) {
- o.elements = buildUnnamed3467();
+ o.elements = buildUnnamed2941();
}
buildCounterIntegerList--;
return o;
@@ -1182,7 +1182,7 @@ buildIntegerList() {
checkIntegerList(api.IntegerList o) {
buildCounterIntegerList++;
if (buildCounterIntegerList < 3) {
- checkUnnamed3467(o.elements);
+ checkUnnamed2941(o.elements);
}
buildCounterIntegerList--;
}
@@ -1208,66 +1208,66 @@ checkIntegerMean(api.IntegerMean o) {
buildCounterIntegerMean--;
}
-buildUnnamed3468() {
+buildUnnamed2942() {
var o = new core.Map<core.String, core.String>();
o["x"] = "foo";
o["y"] = "foo";
return o;
}
-checkUnnamed3468(core.Map<core.String, core.String> o) {
+checkUnnamed2942(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'));
}
-buildUnnamed3469() {
+buildUnnamed2943() {
var o = new core.List<api.ExecutionStageState>();
o.add(buildExecutionStageState());
o.add(buildExecutionStageState());
return o;
}
-checkUnnamed3469(core.List<api.ExecutionStageState> o) {
+checkUnnamed2943(core.List<api.ExecutionStageState> o) {
unittest.expect(o, unittest.hasLength(2));
checkExecutionStageState(o[0]);
checkExecutionStageState(o[1]);
}
-buildUnnamed3470() {
+buildUnnamed2944() {
var o = new core.List<api.Step>();
o.add(buildStep());
o.add(buildStep());
return o;
}
-checkUnnamed3470(core.List<api.Step> o) {
+checkUnnamed2944(core.List<api.Step> o) {
unittest.expect(o, unittest.hasLength(2));
checkStep(o[0]);
checkStep(o[1]);
}
-buildUnnamed3471() {
+buildUnnamed2945() {
var o = new core.List<core.String>();
o.add("foo");
o.add("foo");
return o;
}
-checkUnnamed3471(core.List<core.String> o) {
+checkUnnamed2945(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'));
}
-buildUnnamed3472() {
+buildUnnamed2946() {
var o = new core.Map<core.String, core.String>();
o["x"] = "foo";
o["y"] = "foo";
return o;
}
-checkUnnamed3472(core.Map<core.String, core.String> o) {
+checkUnnamed2946(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'));
@@ -1285,7 +1285,7 @@ buildJob() {
o.environment = buildEnvironment();
o.executionInfo = buildJobExecutionInfo();
o.id = "foo";
- o.labels = buildUnnamed3468();
+ o.labels = buildUnnamed2942();
o.location = "foo";
o.name = "foo";
o.pipelineDescription = buildPipelineDescription();
@@ -1293,10 +1293,10 @@ buildJob() {
o.replaceJobId = "foo";
o.replacedByJobId = "foo";
o.requestedState = "foo";
- o.stageStates = buildUnnamed3469();
- o.steps = buildUnnamed3470();
- o.tempFiles = buildUnnamed3471();
- o.transformNameMapping = buildUnnamed3472();
+ o.stageStates = buildUnnamed2943();
+ o.steps = buildUnnamed2944();
+ o.tempFiles = buildUnnamed2945();
+ o.transformNameMapping = buildUnnamed2946();
o.type = "foo";
}
buildCounterJob--;
@@ -1313,7 +1313,7 @@ checkJob(api.Job o) {
checkEnvironment(o.environment);
checkJobExecutionInfo(o.executionInfo);
unittest.expect(o.id, unittest.equals('foo'));
- checkUnnamed3468(o.labels);
+ checkUnnamed2942(o.labels);
unittest.expect(o.location, unittest.equals('foo'));
unittest.expect(o.name, unittest.equals('foo'));
checkPipelineDescription(o.pipelineDescription);
@@ -1321,23 +1321,23 @@ checkJob(api.Job o) {
unittest.expect(o.replaceJobId, unittest.equals('foo'));
unittest.expect(o.replacedByJobId, unittest.equals('foo'));
unittest.expect(o.requestedState, unittest.equals('foo'));
- checkUnnamed3469(o.stageStates);
- checkUnnamed3470(o.steps);
- checkUnnamed3471(o.tempFiles);
- checkUnnamed3472(o.transformNameMapping);
+ checkUnnamed2943(o.stageStates);
+ checkUnnamed2944(o.steps);
+ checkUnnamed2945(o.tempFiles);
+ checkUnnamed2946(o.transformNameMapping);
unittest.expect(o.type, unittest.equals('foo'));
}
buildCounterJob--;
}
-buildUnnamed3473() {
+buildUnnamed2947() {
var o = new core.Map<core.String, api.JobExecutionStageInfo>();
o["x"] = buildJobExecutionStageInfo();
o["y"] = buildJobExecutionStageInfo();
return o;
}
-checkUnnamed3473(core.Map<core.String, api.JobExecutionStageInfo> o) {
+checkUnnamed2947(core.Map<core.String, api.JobExecutionStageInfo> o) {
unittest.expect(o, unittest.hasLength(2));
checkJobExecutionStageInfo(o["x"]);
checkJobExecutionStageInfo(o["y"]);
@@ -1348,7 +1348,7 @@ buildJobExecutionInfo() {
var o = new api.JobExecutionInfo();
buildCounterJobExecutionInfo++;
if (buildCounterJobExecutionInfo < 3) {
- o.stages = buildUnnamed3473();
+ o.stages = buildUnnamed2947();
}
buildCounterJobExecutionInfo--;
return o;
@@ -1357,19 +1357,19 @@ buildJobExecutionInfo() {
checkJobExecutionInfo(api.JobExecutionInfo o) {
buildCounterJobExecutionInfo++;
if (buildCounterJobExecutionInfo < 3) {
- checkUnnamed3473(o.stages);
+ checkUnnamed2947(o.stages);
}
buildCounterJobExecutionInfo--;
}
-buildUnnamed3474() {
+buildUnnamed2948() {
var o = new core.List<core.String>();
o.add("foo");
o.add("foo");
return o;
}
-checkUnnamed3474(core.List<core.String> o) {
+checkUnnamed2948(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'));
@@ -1380,7 +1380,7 @@ buildJobExecutionStageInfo() {
var o = new api.JobExecutionStageInfo();
buildCounterJobExecutionStageInfo++;
if (buildCounterJobExecutionStageInfo < 3) {
- o.stepName = buildUnnamed3474();
+ o.stepName = buildUnnamed2948();
}
buildCounterJobExecutionStageInfo--;
return o;
@@ -1389,7 +1389,7 @@ buildJobExecutionStageInfo() {
checkJobExecutionStageInfo(api.JobExecutionStageInfo o) {
buildCounterJobExecutionStageInfo++;
if (buildCounterJobExecutionStageInfo < 3) {
- checkUnnamed3474(o.stepName);
+ checkUnnamed2948(o.stepName);
}
buildCounterJobExecutionStageInfo--;
}
@@ -1419,14 +1419,14 @@ checkJobMessage(api.JobMessage o) {
buildCounterJobMessage--;
}
-buildUnnamed3475() {
+buildUnnamed2949() {
var o = new core.List<api.MetricUpdate>();
o.add(buildMetricUpdate());
o.add(buildMetricUpdate());
return o;
}
-checkUnnamed3475(core.List<api.MetricUpdate> o) {
+checkUnnamed2949(core.List<api.MetricUpdate> o) {
unittest.expect(o, unittest.hasLength(2));
checkMetricUpdate(o[0]);
checkMetricUpdate(o[1]);
@@ -1438,7 +1438,7 @@ buildJobMetrics() {
buildCounterJobMetrics++;
if (buildCounterJobMetrics < 3) {
o.metricTime = "foo";
- o.metrics = buildUnnamed3475();
+ o.metrics = buildUnnamed2949();
}
buildCounterJobMetrics--;
return o;
@@ -1448,7 +1448,7 @@ checkJobMetrics(api.JobMetrics o) {
buildCounterJobMetrics++;
if (buildCounterJobMetrics < 3) {
unittest.expect(o.metricTime, unittest.equals('foo'));
- checkUnnamed3475(o.metrics);
+ checkUnnamed2949(o.metrics);
}
buildCounterJobMetrics--;
}
@@ -1503,14 +1503,14 @@ checkKeyRangeLocation(api.KeyRangeLocation o) {
buildCounterKeyRangeLocation--;
}
-buildUnnamed3476() {
+buildUnnamed2950() {
var o = new core.Map<core.String, core.String>();
o["x"] = "foo";
o["y"] = "foo";
return o;
}
-checkUnnamed3476(core.Map<core.String, core.String> o) {
+checkUnnamed2950(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'));
@@ -1523,7 +1523,7 @@ buildLaunchTemplateParameters() {
if (buildCounterLaunchTemplateParameters < 3) {
o.environment = buildRuntimeEnvironment();
o.jobName = "foo";
- o.parameters = buildUnnamed3476();
+ o.parameters = buildUnnamed2950();
}
buildCounterLaunchTemplateParameters--;
return o;
@@ -1534,7 +1534,7 @@ checkLaunchTemplateParameters(api.LaunchTemplateParameters o) {
if (buildCounterLaunchTemplateParameters < 3) {
checkRuntimeEnvironment(o.environment);
unittest.expect(o.jobName, unittest.equals('foo'));
- checkUnnamed3476(o.parameters);
+ checkUnnamed2950(o.parameters);
}
buildCounterLaunchTemplateParameters--;
}
@@ -1558,27 +1558,27 @@ checkLaunchTemplateResponse(api.LaunchTemplateResponse o) {
buildCounterLaunchTemplateResponse--;
}
-buildUnnamed3477() {
+buildUnnamed2951() {
var o = new core.List<core.String>();
o.add("foo");
o.add("foo");
return o;
}
-checkUnnamed3477(core.List<core.String> o) {
+checkUnnamed2951(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'));
}
-buildUnnamed3478() {
+buildUnnamed2952() {
var o = new core.List<core.String>();
o.add("foo");
o.add("foo");
return o;
}
-checkUnnamed3478(core.List<core.String> o) {
+checkUnnamed2952(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'));
@@ -1592,8 +1592,8 @@ buildLeaseWorkItemRequest() {
o.currentWorkerTime = "foo";
o.location = "foo";
o.requestedLeaseDuration = "foo";
- o.workItemTypes = buildUnnamed3477();
- o.workerCapabilities = buildUnnamed3478();
+ o.workItemTypes = buildUnnamed2951();
+ o.workerCapabilities = buildUnnamed2952();
o.workerId = "foo";
}
buildCounterLeaseWorkItemRequest--;
@@ -1606,21 +1606,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'));
- checkUnnamed3477(o.workItemTypes);
- checkUnnamed3478(o.workerCapabilities);
+ checkUnnamed2951(o.workItemTypes);
+ checkUnnamed2952(o.workerCapabilities);
unittest.expect(o.workerId, unittest.equals('foo'));
}
buildCounterLeaseWorkItemRequest--;
}
-buildUnnamed3479() {
+buildUnnamed2953() {
var o = new core.List<api.WorkItem>();
o.add(buildWorkItem());
o.add(buildWorkItem());
return o;
}
-checkUnnamed3479(core.List<api.WorkItem> o) {
+checkUnnamed2953(core.List<api.WorkItem> o) {
unittest.expect(o, unittest.hasLength(2));
checkWorkItem(o[0]);
checkWorkItem(o[1]);
@@ -1631,7 +1631,7 @@ buildLeaseWorkItemResponse() {
var o = new api.LeaseWorkItemResponse();
buildCounterLeaseWorkItemResponse++;
if (buildCounterLeaseWorkItemResponse < 3) {
- o.workItems = buildUnnamed3479();
+ o.workItems = buildUnnamed2953();
}
buildCounterLeaseWorkItemResponse--;
return o;
@@ -1640,32 +1640,32 @@ buildLeaseWorkItemResponse() {
checkLeaseWorkItemResponse(api.LeaseWorkItemResponse o) {
buildCounterLeaseWorkItemResponse++;
if (buildCounterLeaseWorkItemResponse < 3) {
- checkUnnamed3479(o.workItems);
+ checkUnnamed2953(o.workItems);
}
buildCounterLeaseWorkItemResponse--;
}
-buildUnnamed3480() {
+buildUnnamed2954() {
var o = new core.List<api.AutoscalingEvent>();
o.add(buildAutoscalingEvent());
o.add(buildAutoscalingEvent());
return o;
}
-checkUnnamed3480(core.List<api.AutoscalingEvent> o) {
+checkUnnamed2954(core.List<api.AutoscalingEvent> o) {
unittest.expect(o, unittest.hasLength(2));
checkAutoscalingEvent(o[0]);
checkAutoscalingEvent(o[1]);
}
-buildUnnamed3481() {
+buildUnnamed2955() {
var o = new core.List<api.JobMessage>();
o.add(buildJobMessage());
o.add(buildJobMessage());
return o;
}
-checkUnnamed3481(core.List<api.JobMessage> o) {
+checkUnnamed2955(core.List<api.JobMessage> o) {
unittest.expect(o, unittest.hasLength(2));
checkJobMessage(o[0]);
checkJobMessage(o[1]);
@@ -1676,8 +1676,8 @@ buildListJobMessagesResponse() {
var o = new api.ListJobMessagesResponse();
buildCounterListJobMessagesResponse++;
if (buildCounterListJobMessagesResponse < 3) {
- o.autoscalingEvents = buildUnnamed3480();
- o.jobMessages = buildUnnamed3481();
+ o.autoscalingEvents = buildUnnamed2954();
+ o.jobMessages = buildUnnamed2955();
o.nextPageToken = "foo";
}
buildCounterListJobMessagesResponse--;
@@ -1687,34 +1687,34 @@ buildListJobMessagesResponse() {
checkListJobMessagesResponse(api.ListJobMessagesResponse o) {
buildCounterListJobMessagesResponse++;
if (buildCounterListJobMessagesResponse < 3) {
- checkUnnamed3480(o.autoscalingEvents);
- checkUnnamed3481(o.jobMessages);
+ checkUnnamed2954(o.autoscalingEvents);
+ checkUnnamed2955(o.jobMessages);
unittest.expect(o.nextPageToken, unittest.equals('foo'));
}
buildCounterListJobMessagesResponse--;
}
-buildUnnamed3482() {
+buildUnnamed2956() {
var o = new core.List<api.FailedLocation>();
o.add(buildFailedLocation());
o.add(buildFailedLocation());
return o;
}
-checkUnnamed3482(core.List<api.FailedLocation> o) {
+checkUnnamed2956(core.List<api.FailedLocation> o) {
unittest.expect(o, unittest.hasLength(2));
checkFailedLocation(o[0]);
checkFailedLocation(o[1]);
}
-buildUnnamed3483() {
+buildUnnamed2957() {
var o = new core.List<api.Job>();
o.add(buildJob());
o.add(buildJob());
return o;
}
-checkUnnamed3483(core.List<api.Job> o) {
+checkUnnamed2957(core.List<api.Job> o) {
unittest.expect(o, unittest.hasLength(2));
checkJob(o[0]);
checkJob(o[1]);
@@ -1725,8 +1725,8 @@ buildListJobsResponse() {
var o = new api.ListJobsResponse();
buildCounterListJobsResponse++;
if (buildCounterListJobsResponse < 3) {
- o.failedLocation = buildUnnamed3482();
- o.jobs = buildUnnamed3483();
+ o.failedLocation = buildUnnamed2956();
+ o.jobs = buildUnnamed2957();
o.nextPageToken = "foo";
}
buildCounterListJobsResponse--;
@@ -1736,8 +1736,8 @@ buildListJobsResponse() {
checkListJobsResponse(api.ListJobsResponse o) {
buildCounterListJobsResponse++;
if (buildCounterListJobsResponse < 3) {
- checkUnnamed3482(o.failedLocation);
- checkUnnamed3483(o.jobs);
+ checkUnnamed2956(o.failedLocation);
+ checkUnnamed2957(o.jobs);
unittest.expect(o.nextPageToken, unittest.equals('foo'));
}
buildCounterListJobsResponse--;
@@ -1764,14 +1764,14 @@ checkLogBucket(api.LogBucket o) {
buildCounterLogBucket--;
}
-buildUnnamed3484() {
+buildUnnamed2958() {
var o = new core.List<api.ParallelInstruction>();
o.add(buildParallelInstruction());
o.add(buildParallelInstruction());
return o;
}
-checkUnnamed3484(core.List<api.ParallelInstruction> o) {
+checkUnnamed2958(core.List<api.ParallelInstruction> o) {
unittest.expect(o, unittest.hasLength(2));
checkParallelInstruction(o[0]);
checkParallelInstruction(o[1]);
@@ -1782,7 +1782,7 @@ buildMapTask() {
var o = new api.MapTask();
buildCounterMapTask++;
if (buildCounterMapTask < 3) {
- o.instructions = buildUnnamed3484();
+ o.instructions = buildUnnamed2958();
o.stageName = "foo";
o.systemName = "foo";
}
@@ -1793,7 +1793,7 @@ buildMapTask() {
checkMapTask(api.MapTask o) {
buildCounterMapTask++;
if (buildCounterMapTask < 3) {
- checkUnnamed3484(o.instructions);
+ checkUnnamed2958(o.instructions);
unittest.expect(o.stageName, unittest.equals('foo'));
unittest.expect(o.systemName, unittest.equals('foo'));
}
@@ -1821,14 +1821,14 @@ checkMetricShortId(api.MetricShortId o) {
buildCounterMetricShortId--;
}
-buildUnnamed3485() {
+buildUnnamed2959() {
var o = new core.Map<core.String, core.String>();
o["x"] = "foo";
o["y"] = "foo";
return o;
}
-checkUnnamed3485(core.Map<core.String, core.String> o) {
+checkUnnamed2959(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'));
@@ -1839,7 +1839,7 @@ buildMetricStructuredName() {
var o = new api.MetricStructuredName();
buildCounterMetricStructuredName++;
if (buildCounterMetricStructuredName < 3) {
- o.context = buildUnnamed3485();
+ o.context = buildUnnamed2959();
o.name = "foo";
o.origin = "foo";
}
@@ -1850,7 +1850,7 @@ buildMetricStructuredName() {
checkMetricStructuredName(api.MetricStructuredName o) {
buildCounterMetricStructuredName++;
if (buildCounterMetricStructuredName < 3) {
- checkUnnamed3485(o.context);
+ checkUnnamed2959(o.context);
unittest.expect(o.name, unittest.equals('foo'));
unittest.expect(o.origin, unittest.equals('foo'));
}
@@ -1974,40 +1974,40 @@ checkPackage(api.Package o) {
buildCounterPackage--;
}
-buildUnnamed3486() {
+buildUnnamed2960() {
var o = new core.List<api.MultiOutputInfo>();
o.add(buildMultiOutputInfo());
o.add(buildMultiOutputInfo());
return o;
}
-checkUnnamed3486(core.List<api.MultiOutputInfo> o) {
+checkUnnamed2960(core.List<api.MultiOutputInfo> o) {
unittest.expect(o, unittest.hasLength(2));
checkMultiOutputInfo(o[0]);
checkMultiOutputInfo(o[1]);
}
-buildUnnamed3487() {
+buildUnnamed2961() {
var o = new core.List<api.SideInputInfo>();
o.add(buildSideInputInfo());
o.add(buildSideInputInfo());
return o;
}
-checkUnnamed3487(core.List<api.SideInputInfo> o) {
+checkUnnamed2961(core.List<api.SideInputInfo> o) {
unittest.expect(o, unittest.hasLength(2));
checkSideInputInfo(o[0]);
checkSideInputInfo(o[1]);
}
-buildUnnamed3488() {
+buildUnnamed2962() {
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;
}
-checkUnnamed3488(core.Map<core.String, core.Object> o) {
+checkUnnamed2962(core.Map<core.String, core.Object> o) {
unittest.expect(o, unittest.hasLength(2));
var casted18 = (o["x"]) 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'));
var casted19 = (o["y"]) 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'));
@@ -2019,10 +2019,10 @@ buildParDoInstruction() {
buildCounterParDoInstruction++;
if (buildCounterParDoInstruction < 3) {
o.input = buildInstructionInput();
- o.multiOutputInfos = buildUnnamed3486();
+ o.multiOutputInfos = buildUnnamed2960();
o.numOutputs = 42;
- o.sideInputs = buildUnnamed3487();
- o.userFn = buildUnnamed3488();
+ o.sideInputs = buildUnnamed2961();
+ o.userFn = buildUnnamed2962();
}
buildCounterParDoInstruction--;
return o;
@@ -2032,22 +2032,22 @@ checkParDoInstruction(api.ParDoInstruction o) {
buildCounterParDoInstruction++;
if (buildCounterParDoInstruction < 3) {
checkInstructionInput(o.input);
- checkUnnamed3486(o.multiOutputInfos);
+ checkUnnamed2960(o.multiOutputInfos);
unittest.expect(o.numOutputs, unittest.equals(42));
- checkUnnamed3487(o.sideInputs);
- checkUnnamed3488(o.userFn);
+ checkUnnamed2961(o.sideInputs);
+ checkUnnamed2962(o.userFn);
}
buildCounterParDoInstruction--;
}
-buildUnnamed3489() {
+buildUnnamed2963() {
var o = new core.List<api.InstructionOutput>();
o.add(buildInstructionOutput());
o.add(buildInstructionOutput());
return o;
}
-checkUnnamed3489(core.List<api.InstructionOutput> o) {
+checkUnnamed2963(core.List<api.InstructionOutput> o) {
unittest.expect(o, unittest.hasLength(2));
checkInstructionOutput(o[0]);
checkInstructionOutput(o[1]);
@@ -2061,7 +2061,7 @@ buildParallelInstruction() {
o.flatten = buildFlattenInstruction();
o.name = "foo";
o.originalName = "foo";
- o.outputs = buildUnnamed3489();
+ o.outputs = buildUnnamed2963();
o.parDo = buildParDoInstruction();
o.partialGroupByKey = buildPartialGroupByKeyInstruction();
o.read = buildReadInstruction();
@@ -2078,7 +2078,7 @@ checkParallelInstruction(api.ParallelInstruction o) {
checkFlattenInstruction(o.flatten);
unittest.expect(o.name, unittest.equals('foo'));
unittest.expect(o.originalName, unittest.equals('foo'));
- checkUnnamed3489(o.outputs);
+ checkUnnamed2963(o.outputs);
checkParDoInstruction(o.parDo);
checkPartialGroupByKeyInstruction(o.partialGroupByKey);
checkReadInstruction(o.read);
@@ -2109,14 +2109,14 @@ checkParameter(api.Parameter o) {
buildCounterParameter--;
}
-buildUnnamed3490() {
+buildUnnamed2964() {
var o = new core.List<core.String>();
o.add("foo");
o.add("foo");
return o;
}
-checkUnnamed3490(core.List<core.String> o) {
+checkUnnamed2964(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'));
@@ -2131,7 +2131,7 @@ buildParameterMetadata() {
o.isOptional = true;
o.label = "foo";
o.name = "foo";
- o.regexes = buildUnnamed3490();
+ o.regexes = buildUnnamed2964();
}
buildCounterParameterMetadata--;
return o;
@@ -2144,45 +2144,45 @@ checkParameterMetadata(api.ParameterMetadata o) {
unittest.expect(o.isOptional, unittest.isTrue);
unittest.expect(o.label, unittest.equals('foo'));
unittest.expect(o.name, unittest.equals('foo'));
- checkUnnamed3490(o.regexes);
+ checkUnnamed2964(o.regexes);
}
buildCounterParameterMetadata--;
}
-buildUnnamed3491() {
+buildUnnamed2965() {
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;
}
-checkUnnamed3491(core.Map<core.String, core.Object> o) {
+checkUnnamed2965(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'));
}
-buildUnnamed3492() {
+buildUnnamed2966() {
var o = new core.List<api.SideInputInfo>();
o.add(buildSideInputInfo());
o.add(buildSideInputInfo());
return o;
}
-checkUnnamed3492(core.List<api.SideInputInfo> o) {
+checkUnnamed2966(core.List<api.SideInputInfo> o) {
unittest.expect(o, unittest.hasLength(2));
checkSideInputInfo(o[0]);
checkSideInputInfo(o[1]);
}
-buildUnnamed3493() {
+buildUnnamed2967() {
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;
}
-checkUnnamed3493(core.Map<core.String, core.Object> o) {
+checkUnnamed2967(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'));
@@ -2194,11 +2194,11 @@ buildPartialGroupByKeyInstruction() {
buildCounterPartialGroupByKeyInstruction++;
if (buildCounterPartialGroupByKeyInstruction < 3) {
o.input = buildInstructionInput();
- o.inputElementCodec = buildUnnamed3491();
+ o.inputElementCodec = buildUnnamed2965();
o.originalCombineValuesInputStoreName = "foo";
o.originalCombineValuesStepName = "foo";
- o.sideInputs = buildUnnamed3492();
- o.valueCombiningFn = buildUnnamed3493();
+ o.sideInputs = buildUnnamed2966();
+ o.valueCombiningFn = buildUnnamed2967();
}
buildCounterPartialGroupByKeyInstruction--;
return o;
@@ -2208,49 +2208,49 @@ checkPartialGroupByKeyInstruction(api.PartialGroupByKeyInstruction o) {
buildCounterPartialGroupByKeyInstruction++;
if (buildCounterPartialGroupByKeyInstruction < 3) {
checkInstructionInput(o.input);
- checkUnnamed3491(o.inputElementCodec);
+ checkUnnamed2965(o.inputElementCodec);
unittest.expect(o.originalCombineValuesInputStoreName, unittest.equals('foo'));
unittest.expect(o.originalCombineValuesStepName, unittest.equals('foo'));
- checkUnnamed3492(o.sideInputs);
- checkUnnamed3493(o.valueCombiningFn);
+ checkUnnamed2966(o.sideInputs);
+ checkUnnamed2967(o.valueCombiningFn);
}
buildCounterPartialGroupByKeyInstruction--;
}
-buildUnnamed3494() {
+buildUnnamed2968() {
var o = new core.List<api.DisplayData>();
o.add(buildDisplayData());
o.add(buildDisplayData());
return o;
}
-checkUnnamed3494(core.List<api.DisplayData> o) {
+checkUnnamed2968(core.List<api.DisplayData> o) {
unittest.expect(o, unittest.hasLength(2));
checkDisplayData(o[0]);
checkDisplayData(o[1]);
}
-buildUnnamed3495() {
+buildUnnamed2969() {
var o = new core.List<api.ExecutionStageSummary>();
o.add(buildExecutionStageSummary());
o.add(buildExecutionStageSummary());
return o;
}
-checkUnnamed3495(core.List<api.ExecutionStageSummary> o) {
+checkUnnamed2969(core.List<api.ExecutionStageSummary> o) {
unittest.expect(o, unittest.hasLength(2));
checkExecutionStageSummary(o[0]);
checkExecutionStageSummary(o[1]);
}
-buildUnnamed3496() {
+buildUnnamed2970() {
var o = new core.List<api.TransformSummary>();
o.add(buildTransformSummary());
o.add(buildTransformSummary());
return o;
}
-checkUnnamed3496(core.List<api.TransformSummary> o) {
+checkUnnamed2970(core.List<api.TransformSummary> o) {
unittest.expect(o, unittest.hasLength(2));
checkTransformSummary(o[0]);
checkTransformSummary(o[1]);
@@ -2261,9 +2261,9 @@ buildPipelineDescription() {
var o = new api.PipelineDescription();
buildCounterPipelineDescription++;
if (buildCounterPipelineDescription < 3) {
- o.displayData = buildUnnamed3494();
- o.executionPipelineStage = buildUnnamed3495();
- o.originalPipelineTransform = buildUnnamed3496();
+ o.displayData = buildUnnamed2968();
+ o.executionPipelineStage = buildUnnamed2969();
+ o.originalPipelineTransform = buildUnnamed2970();
}
buildCounterPipelineDescription--;
return o;
@@ -2272,9 +2272,9 @@ buildPipelineDescription() {
checkPipelineDescription(api.PipelineDescription o) {
buildCounterPipelineDescription++;
if (buildCounterPipelineDescription < 3) {
- checkUnnamed3494(o.displayData);
- checkUnnamed3495(o.executionPipelineStage);
- checkUnnamed3496(o.originalPipelineTransform);
+ checkUnnamed2968(o.displayData);
+ checkUnnamed2969(o.executionPipelineStage);
+ checkUnnamed2970(o.originalPipelineTransform);
}
buildCounterPipelineDescription--;
}
@@ -2358,14 +2358,14 @@ checkReadInstruction(api.ReadInstruction o) {
buildCounterReadInstruction--;
}
-buildUnnamed3497() {
+buildUnnamed2971() {
var o = new core.List<api.WorkItemStatus>();
o.add(buildWorkItemStatus());
o.add(buildWorkItemStatus());
return o;
}
-checkUnnamed3497(core.List<api.WorkItemStatus> o) {
+checkUnnamed2971(core.List<api.WorkItemStatus> o) {
unittest.expect(o, unittest.hasLength(2));
checkWorkItemStatus(o[0]);
checkWorkItemStatus(o[1]);
@@ -2378,7 +2378,7 @@ buildReportWorkItemStatusRequest() {
if (buildCounterReportWorkItemStatusRequest < 3) {
o.currentWorkerTime = "foo";
o.location = "foo";
- o.workItemStatuses = buildUnnamed3497();
+ o.workItemStatuses = buildUnnamed2971();
o.workerId = "foo";
}
buildCounterReportWorkItemStatusRequest--;
@@ -2390,20 +2390,20 @@ checkReportWorkItemStatusRequest(api.ReportWorkItemStatusRequest o) {
if (buildCounterReportWorkItemStatusRequest < 3) {
unittest.expect(o.currentWorkerTime, unittest.equals('foo'));
unittest.expect(o.location, unittest.equals('foo'));
- checkUnnamed3497(o.workItemStatuses);
+ checkUnnamed2971(o.workItemStatuses);
unittest.expect(o.workerId, unittest.equals('foo'));
}
buildCounterReportWorkItemStatusRequest--;
}
-buildUnnamed3498() {
+buildUnnamed2972() {
var o = new core.List<api.WorkItemServiceState>();
o.add(buildWorkItemServiceState());
o.add(buildWorkItemServiceState());
return o;
}
-checkUnnamed3498(core.List<api.WorkItemServiceState> o) {
+checkUnnamed2972(core.List<api.WorkItemServiceState> o) {
unittest.expect(o, unittest.hasLength(2));
checkWorkItemServiceState(o[0]);
checkWorkItemServiceState(o[1]);
@@ -2414,7 +2414,7 @@ buildReportWorkItemStatusResponse() {
var o = new api.ReportWorkItemStatusResponse();
buildCounterReportWorkItemStatusResponse++;
if (buildCounterReportWorkItemStatusResponse < 3) {
- o.workItemServiceStates = buildUnnamed3498();
+ o.workItemServiceStates = buildUnnamed2972();
}
buildCounterReportWorkItemStatusResponse--;
return o;
@@ -2423,7 +2423,7 @@ buildReportWorkItemStatusResponse() {
checkReportWorkItemStatusResponse(api.ReportWorkItemStatusResponse o) {
buildCounterReportWorkItemStatusResponse++;
if (buildCounterReportWorkItemStatusResponse < 3) {
- checkUnnamed3498(o.workItemServiceStates);
+ checkUnnamed2972(o.workItemServiceStates);
}
buildCounterReportWorkItemStatusResponse--;
}
@@ -2449,14 +2449,14 @@ checkReportedParallelism(api.ReportedParallelism o) {
buildCounterReportedParallelism--;
}
-buildUnnamed3499() {
+buildUnnamed2973() {
var o = new core.List<api.CPUTime>();
o.add(buildCPUTime());
o.add(buildCPUTime());
return o;
}
-checkUnnamed3499(core.List<api.CPUTime> o) {
+checkUnnamed2973(core.List<api.CPUTime> o) {
unittest.expect(o, unittest.hasLength(2));
checkCPUTime(o[0]);
checkCPUTime(o[1]);
@@ -2467,7 +2467,7 @@ buildResourceUtilizationReport() {
var o = new api.ResourceUtilizationReport();
buildCounterResourceUtilizationReport++;
if (buildCounterResourceUtilizationReport < 3) {
- o.cpuTime = buildUnnamed3499();
+ o.cpuTime = buildUnnamed2973();
}
buildCounterResourceUtilizationReport--;
return o;
@@ -2476,7 +2476,7 @@ buildResourceUtilizationReport() {
checkResourceUtilizationReport(api.ResourceUtilizationReport o) {
buildCounterResourceUtilizationReport++;
if (buildCounterResourceUtilizationReport < 3) {
- checkUnnamed3499(o.cpuTime);
+ checkUnnamed2973(o.cpuTime);
}
buildCounterResourceUtilizationReport--;
}
@@ -2569,14 +2569,14 @@ checkSendDebugCaptureResponse(api.SendDebugCaptureResponse o) {
buildCounterSendDebugCaptureResponse--;
}
-buildUnnamed3500() {
+buildUnnamed2974() {
var o = new core.List<api.WorkerMessage>();
o.add(buildWorkerMessage());
o.add(buildWorkerMessage());
return o;
}
-checkUnnamed3500(core.List<api.WorkerMessage> o) {
+checkUnnamed2974(core.List<api.WorkerMessage> o) {
unittest.expect(o, unittest.hasLength(2));
checkWorkerMessage(o[0]);
checkWorkerMessage(o[1]);
@@ -2588,7 +2588,7 @@ buildSendWorkerMessagesRequest() {
buildCounterSendWorkerMessagesRequest++;
if (buildCounterSendWorkerMessagesRequest < 3) {
o.location = "foo";
- o.workerMessages = buildUnnamed3500();
+ o.workerMessages = buildUnnamed2974();
}
buildCounterSendWorkerMessagesRequest--;
return o;
@@ -2598,19 +2598,19 @@ checkSendWorkerMessagesRequest(api.SendWorkerMessagesRequest o) {
buildCounterSendWorkerMessagesRequest++;
if (buildCounterSendWorkerMessagesRequest < 3) {
unittest.expect(o.location, unittest.equals('foo'));
- checkUnnamed3500(o.workerMessages);
+ checkUnnamed2974(o.workerMessages);
}
buildCounterSendWorkerMessagesRequest--;
}
-buildUnnamed3501() {
+buildUnnamed2975() {
var o = new core.List<api.WorkerMessageResponse>();
o.add(buildWorkerMessageResponse());
o.add(buildWorkerMessageResponse());
return o;
}
-checkUnnamed3501(core.List<api.WorkerMessageResponse> o) {
+checkUnnamed2975(core.List<api.WorkerMessageResponse> o) {
unittest.expect(o, unittest.hasLength(2));
checkWorkerMessageResponse(o[0]);
checkWorkerMessageResponse(o[1]);
@@ -2621,7 +2621,7 @@ buildSendWorkerMessagesResponse() {
var o = new api.SendWorkerMessagesResponse();
buildCounterSendWorkerMessagesResponse++;
if (buildCounterSendWorkerMessagesResponse < 3) {
- o.workerMessageResponses = buildUnnamed3501();
+ o.workerMessageResponses = buildUnnamed2975();
}
buildCounterSendWorkerMessagesResponse--;
return o;
@@ -2630,45 +2630,45 @@ buildSendWorkerMessagesResponse() {
checkSendWorkerMessagesResponse(api.SendWorkerMessagesResponse o) {
buildCounterSendWorkerMessagesResponse++;
if (buildCounterSendWorkerMessagesResponse < 3) {
- checkUnnamed3501(o.workerMessageResponses);
+ checkUnnamed2975(o.workerMessageResponses);
}
buildCounterSendWorkerMessagesResponse--;
}
-buildUnnamed3502() {
+buildUnnamed2976() {
var o = new core.List<api.SideInputInfo>();
o.add(buildSideInputInfo());
o.add(buildSideInputInfo());
return o;
}
-checkUnnamed3502(core.List<api.SideInputInfo> o) {
+checkUnnamed2976(core.List<api.SideInputInfo> o) {
unittest.expect(o, unittest.hasLength(2));
checkSideInputInfo(o[0]);
checkSideInputInfo(o[1]);
}
-buildUnnamed3503() {
+buildUnnamed2977() {
var o = new core.List<api.SeqMapTaskOutputInfo>();
o.add(buildSeqMapTaskOutputInfo());
o.add(buildSeqMapTaskOutputInfo());
return o;
}
-checkUnnamed3503(core.List<api.SeqMapTaskOutputInfo> o) {
+checkUnnamed2977(core.List<api.SeqMapTaskOutputInfo> o) {
unittest.expect(o, unittest.hasLength(2));
checkSeqMapTaskOutputInfo(o[0]);
checkSeqMapTaskOutputInfo(o[1]);
}
-buildUnnamed3504() {
+buildUnnamed2978() {
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;
}
-checkUnnamed3504(core.Map<core.String, core.Object> o) {
+checkUnnamed2978(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'));
@@ -2679,12 +2679,12 @@ buildSeqMapTask() {
var o = new api.SeqMapTask();
buildCounterSeqMapTask++;
if (buildCounterSeqMapTask < 3) {
- o.inputs = buildUnnamed3502();
+ o.inputs = buildUnnamed2976();
o.name = "foo";
- o.outputInfos = buildUnnamed3503();
+ o.outputInfos = buildUnnamed2977();
o.stageName = "foo";
o.systemName = "foo";
- o.userFn = buildUnnamed3504();
+ o.userFn = buildUnnamed2978();
}
buildCounterSeqMapTask--;
return o;
@@ -2693,12 +2693,12 @@ buildSeqMapTask() {
checkSeqMapTask(api.SeqMapTask o) {
buildCounterSeqMapTask++;
if (buildCounterSeqMapTask < 3) {
- checkUnnamed3502(o.inputs);
+ checkUnnamed2976(o.inputs);
unittest.expect(o.name, unittest.equals('foo'));
- checkUnnamed3503(o.outputInfos);
+ checkUnnamed2977(o.outputInfos);
unittest.expect(o.stageName, unittest.equals('foo'));
unittest.expect(o.systemName, unittest.equals('foo'));
- checkUnnamed3504(o.userFn);
+ checkUnnamed2978(o.userFn);
}
buildCounterSeqMapTask--;
}
@@ -2745,27 +2745,27 @@ checkShellTask(api.ShellTask o) {
buildCounterShellTask--;
}
-buildUnnamed3505() {
+buildUnnamed2979() {
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;
}
-checkUnnamed3505(core.Map<core.String, core.Object> o) {
+checkUnnamed2979(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'));
}
-buildUnnamed3506() {
+buildUnnamed2980() {
var o = new core.List<api.Source>();
o.add(buildSource());
o.add(buildSource());
return o;
}
-checkUnnamed3506(core.List<api.Source> o) {
+checkUnnamed2980(core.List<api.Source> o) {
unittest.expect(o, unittest.hasLength(2));
checkSource(o[0]);
checkSource(o[1]);
@@ -2776,8 +2776,8 @@ buildSideInputInfo() {
var o = new api.SideInputInfo();
buildCounterSideInputInfo++;
if (buildCounterSideInputInfo < 3) {
- o.kind = buildUnnamed3505();
- o.sources = buildUnnamed3506();
+ o.kind = buildUnnamed2979();
+ o.sources = buildUnnamed2980();
o.tag = "foo";
}
buildCounterSideInputInfo--;
@@ -2787,34 +2787,34 @@ buildSideInputInfo() {
checkSideInputInfo(api.SideInputInfo o) {
buildCounterSideInputInfo++;
if (buildCounterSideInputInfo < 3) {
- checkUnnamed3505(o.kind);
- checkUnnamed3506(o.sources);
+ checkUnnamed2979(o.kind);
+ checkUnnamed2980(o.sources);
unittest.expect(o.tag, unittest.equals('foo'));
}
buildCounterSideInputInfo--;
}
-buildUnnamed3507() {
+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;
}
-checkUnnamed3507(core.Map<core.String, core.Object> o) {
+checkUnnamed2981(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'));
}
-buildUnnamed3508() {
+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;
}
-checkUnnamed3508(core.Map<core.String, core.Object> o) {
+checkUnnamed2982(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'));
@@ -2825,8 +2825,8 @@ buildSink() {
var o = new api.Sink();
buildCounterSink++;
if (buildCounterSink < 3) {
- o.codec = buildUnnamed3507();
- o.spec = buildUnnamed3508();
+ o.codec = buildUnnamed2981();
+ o.spec = buildUnnamed2982();
}
buildCounterSink--;
return o;
@@ -2835,59 +2835,59 @@ buildSink() {
checkSink(api.Sink o) {
buildCounterSink++;
if (buildCounterSink < 3) {
- checkUnnamed3507(o.codec);
- checkUnnamed3508(o.spec);
+ checkUnnamed2981(o.codec);
+ checkUnnamed2982(o.spec);
}
buildCounterSink--;
}
-buildUnnamed3509() {
+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;
}
-checkUnnamed3509(core.Map<core.String, core.Object> o) {
+checkUnnamed2983(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'));
}
-buildUnnamed3510() {
+buildUnnamed2984() {
var o = new core.List<core.Map<core.String, core.Object>>();
- o.add(buildUnnamed3509());
- o.add(buildUnnamed3509());
+ o.add(buildUnnamed2983());
+ o.add(buildUnnamed2983());
return o;
}
-checkUnnamed3510(core.List<core.Map<core.String, core.Object>> o) {
+checkUnnamed2984(core.List<core.Map<core.String, core.Object>> o) {
unittest.expect(o, unittest.hasLength(2));
- checkUnnamed3509(o[0]);
- checkUnnamed3509(o[1]);
+ checkUnnamed2983(o[0]);
+ checkUnnamed2983(o[1]);
}
-buildUnnamed3511() {
+buildUnnamed2985() {
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;
}
-checkUnnamed3511(core.Map<core.String, core.Object> o) {
+checkUnnamed2985(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'));
}
-buildUnnamed3512() {
+buildUnnamed2986() {
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;
}
-checkUnnamed3512(core.Map<core.String, core.Object> o) {
+checkUnnamed2986(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'));
@@ -2898,11 +2898,11 @@ buildSource() {
var o = new api.Source();
buildCounterSource++;
if (buildCounterSource < 3) {
- o.baseSpecs = buildUnnamed3510();
- o.codec = buildUnnamed3511();
+ o.baseSpecs = buildUnnamed2984();
+ o.codec = buildUnnamed2985();
o.doesNotNeedSplitting = true;
o.metadata = buildSourceMetadata();
- o.spec = buildUnnamed3512();
+ o.spec = buildUnnamed2986();
}
buildCounterSource--;
return o;
@@ -2911,11 +2911,11 @@ buildSource() {
checkSource(api.Source o) {
buildCounterSource++;
if (buildCounterSource < 3) {
- checkUnnamed3510(o.baseSpecs);
- checkUnnamed3511(o.codec);
+ checkUnnamed2984(o.baseSpecs);
+ checkUnnamed2985(o.codec);
unittest.expect(o.doesNotNeedSplitting, unittest.isTrue);
checkSourceMetadata(o.metadata);
- checkUnnamed3512(o.spec);
+ checkUnnamed2986(o.spec);
}
buildCounterSource--;
}
@@ -3090,27 +3090,27 @@ checkSourceSplitRequest(api.SourceSplitRequest o) {
buildCounterSourceSplitRequest--;
}
-buildUnnamed3513() {
+buildUnnamed2987() {
var o = new core.List<api.DerivedSource>();
o.add(buildDerivedSource());
o.add(buildDerivedSource());
return o;
}
-checkUnnamed3513(core.List<api.DerivedSource> o) {
+checkUnnamed2987(core.List<api.DerivedSource> o) {
unittest.expect(o, unittest.hasLength(2));
checkDerivedSource(o[0]);
checkDerivedSource(o[1]);
}
-buildUnnamed3514() {
+buildUnnamed2988() {
var o = new core.List<api.SourceSplitShard>();
o.add(buildSourceSplitShard());
o.add(buildSourceSplitShard());
return o;
}
-checkUnnamed3514(core.List<api.SourceSplitShard> o) {
+checkUnnamed2988(core.List<api.SourceSplitShard> o) {
unittest.expect(o, unittest.hasLength(2));
checkSourceSplitShard(o[0]);
checkSourceSplitShard(o[1]);
@@ -3121,9 +3121,9 @@ buildSourceSplitResponse() {
var o = new api.SourceSplitResponse();
buildCounterSourceSplitResponse++;
if (buildCounterSourceSplitResponse < 3) {
- o.bundles = buildUnnamed3513();
+ o.bundles = buildUnnamed2987();
o.outcome = "foo";
- o.shards = buildUnnamed3514();
+ o.shards = buildUnnamed2988();
}
buildCounterSourceSplitResponse--;
return o;
@@ -3132,9 +3132,9 @@ buildSourceSplitResponse() {
checkSourceSplitResponse(api.SourceSplitResponse o) {
buildCounterSourceSplitResponse++;
if (buildCounterSourceSplitResponse < 3) {
- checkUnnamed3513(o.bundles);
+ checkUnnamed2987(o.bundles);
unittest.expect(o.outcome, unittest.equals('foo'));
- checkUnnamed3514(o.shards);
+ checkUnnamed2988(o.shards);
}
buildCounterSourceSplitResponse--;
}
@@ -3227,30 +3227,30 @@ checkStateFamilyConfig(api.StateFamilyConfig o) {
buildCounterStateFamilyConfig--;
}
-buildUnnamed3515() {
+buildUnnamed2989() {
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;
}
-checkUnnamed3515(core.Map<core.String, core.Object> o) {
+checkUnnamed2989(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'));
}
-buildUnnamed3516() {
+buildUnnamed2990() {
var o = new core.List<core.Map<core.String, core.Object>>();
- o.add(buildUnnamed3515());
- o.add(buildUnnamed3515());
+ o.add(buildUnnamed2989());
+ o.add(buildUnnamed2989());
return o;
}
-checkUnnamed3516(core.List<core.Map<core.String, core.Object>> o) {
+checkUnnamed2990(core.List<core.Map<core.String, core.Object>> o) {
unittest.expect(o, unittest.hasLength(2));
- checkUnnamed3515(o[0]);
- checkUnnamed3515(o[1]);
+ checkUnnamed2989(o[0]);
+ checkUnnamed2989(o[1]);
}
core.int buildCounterStatus = 0;
@@ -3259,7 +3259,7 @@ buildStatus() {
buildCounterStatus++;
if (buildCounterStatus < 3) {
o.code = 42;
- o.details = buildUnnamed3516();
+ o.details = buildUnnamed2990();
o.message = "foo";
}
buildCounterStatus--;
@@ -3270,20 +3270,20 @@ checkStatus(api.Status o) {
buildCounterStatus++;
if (buildCounterStatus < 3) {
unittest.expect(o.code, unittest.equals(42));
- checkUnnamed3516(o.details);
+ checkUnnamed2990(o.details);
unittest.expect(o.message, unittest.equals('foo'));
}
buildCounterStatus--;
}
-buildUnnamed3517() {
+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;
}
-checkUnnamed3517(core.Map<core.String, core.Object> o) {
+checkUnnamed2991(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'));
@@ -3296,7 +3296,7 @@ buildStep() {
if (buildCounterStep < 3) {
o.kind = "foo";
o.name = "foo";
- o.properties = buildUnnamed3517();
+ o.properties = buildUnnamed2991();
}
buildCounterStep--;
return o;
@@ -3307,7 +3307,7 @@ checkStep(api.Step o) {
if (buildCounterStep < 3) {
unittest.expect(o.kind, unittest.equals('foo'));
unittest.expect(o.name, unittest.equals('foo'));
- checkUnnamed3517(o.properties);
+ checkUnnamed2991(o.properties);
}
buildCounterStep--;
}
@@ -3337,14 +3337,14 @@ checkStreamLocation(api.StreamLocation o) {
buildCounterStreamLocation--;
}
-buildUnnamed3518() {
+buildUnnamed2992() {
var o = new core.List<api.ParallelInstruction>();
o.add(buildParallelInstruction());
o.add(buildParallelInstruction());
return o;
}
-checkUnnamed3518(core.List<api.ParallelInstruction> o) {
+checkUnnamed2992(core.List<api.ParallelInstruction> o) {
unittest.expect(o, unittest.hasLength(2));
checkParallelInstruction(o[0]);
checkParallelInstruction(o[1]);
@@ -3356,7 +3356,7 @@ buildStreamingComputationConfig() {
buildCounterStreamingComputationConfig++;
if (buildCounterStreamingComputationConfig < 3) {
o.computationId = "foo";
- o.instructions = buildUnnamed3518();
+ o.instructions = buildUnnamed2992();
o.stageName = "foo";
o.systemName = "foo";
}
@@ -3368,21 +3368,21 @@ checkStreamingComputationConfig(api.StreamingComputationConfig o) {
buildCounterStreamingComputationConfig++;
if (buildCounterStreamingComputationConfig < 3) {
unittest.expect(o.computationId, unittest.equals('foo'));
- checkUnnamed3518(o.instructions);
+ checkUnnamed2992(o.instructions);
unittest.expect(o.stageName, unittest.equals('foo'));
unittest.expect(o.systemName, unittest.equals('foo'));
}
buildCounterStreamingComputationConfig--;
}
-buildUnnamed3519() {
+buildUnnamed2993() {
var o = new core.List<api.KeyRangeDataDiskAssignment>();
o.add(buildKeyRangeDataDiskAssignment());
o.add(buildKeyRangeDataDiskAssignment());
return o;
}
-checkUnnamed3519(core.List<api.KeyRangeDataDiskAssignment> o) {
+checkUnnamed2993(core.List<api.KeyRangeDataDiskAssignment> o) {
unittest.expect(o, unittest.hasLength(2));
checkKeyRangeDataDiskAssignment(o[0]);
checkKeyRangeDataDiskAssignment(o[1]);
@@ -3394,7 +3394,7 @@ buildStreamingComputationRanges() {
buildCounterStreamingComputationRanges++;
if (buildCounterStreamingComputationRanges < 3) {
o.computationId = "foo";
- o.rangeAssignments = buildUnnamed3519();
+ o.rangeAssignments = buildUnnamed2993();
}
buildCounterStreamingComputationRanges--;
return o;
@@ -3404,32 +3404,32 @@ checkStreamingComputationRanges(api.StreamingComputationRanges o) {
buildCounterStreamingComputationRanges++;
if (buildCounterStreamingComputationRanges < 3) {
unittest.expect(o.computationId, unittest.equals('foo'));
- checkUnnamed3519(o.rangeAssignments);
+ checkUnnamed2993(o.rangeAssignments);
}
buildCounterStreamingComputationRanges--;
}
-buildUnnamed3520() {
+buildUnnamed2994() {
var o = new core.List<api.StreamingComputationRanges>();
o.add(buildStreamingComputationRanges());
o.add(buildStreamingComputationRanges());
return o;
}
-checkUnnamed3520(core.List<api.StreamingComputationRanges> o) {
+checkUnnamed2994(core.List<api.StreamingComputationRanges> o) {
unittest.expect(o, unittest.hasLength(2));
checkStreamingComputationRanges(o[0]);
checkStreamingComputationRanges(o[1]);
}
-buildUnnamed3521() {
+buildUnnamed2995() {
var o = new core.List<api.MountedDataDisk>();
o.add(buildMountedDataDisk());
o.add(buildMountedDataDisk());
return o;
}
-checkUnnamed3521(core.List<api.MountedDataDisk> o) {
+checkUnnamed2995(core.List<api.MountedDataDisk> o) {
unittest.expect(o, unittest.hasLength(2));
checkMountedDataDisk(o[0]);
checkMountedDataDisk(o[1]);
@@ -3440,8 +3440,8 @@ buildStreamingComputationTask() {
var o = new api.StreamingComputationTask();
buildCounterStreamingComputationTask++;
if (buildCounterStreamingComputationTask < 3) {
- o.computationRanges = buildUnnamed3520();
- o.dataDisks = buildUnnamed3521();
+ o.computationRanges = buildUnnamed2994();
+ o.dataDisks = buildUnnamed2995();
o.taskType = "foo";
}
buildCounterStreamingComputationTask--;
@@ -3451,34 +3451,34 @@ buildStreamingComputationTask() {
checkStreamingComputationTask(api.StreamingComputationTask o) {
buildCounterStreamingComputationTask++;
if (buildCounterStreamingComputationTask < 3) {
- checkUnnamed3520(o.computationRanges);
- checkUnnamed3521(o.dataDisks);
+ checkUnnamed2994(o.computationRanges);
+ checkUnnamed2995(o.dataDisks);
unittest.expect(o.taskType, unittest.equals('foo'));
}
buildCounterStreamingComputationTask--;
}
-buildUnnamed3522() {
+buildUnnamed2996() {
var o = new core.List<api.StreamingComputationConfig>();
o.add(buildStreamingComputationConfig());
o.add(buildStreamingComputationConfig());
return o;
}
-checkUnnamed3522(core.List<api.StreamingComputationConfig> o) {
+checkUnnamed2996(core.List<api.StreamingComputationConfig> o) {
unittest.expect(o, unittest.hasLength(2));
checkStreamingComputationConfig(o[0]);
checkStreamingComputationConfig(o[1]);
}
-buildUnnamed3523() {
+buildUnnamed2997() {
var o = new core.Map<core.String, core.String>();
o["x"] = "foo";
o["y"] = "foo";
return o;
}
-checkUnnamed3523(core.Map<core.String, core.String> o) {
+checkUnnamed2997(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'));
@@ -3489,8 +3489,8 @@ buildStreamingConfigTask() {
var o = new api.StreamingConfigTask();
buildCounterStreamingConfigTask++;
if (buildCounterStreamingConfigTask < 3) {
- o.streamingComputationConfigs = buildUnnamed3522();
- o.userStepToStateFamilyNameMap = buildUnnamed3523();
+ o.streamingComputationConfigs = buildUnnamed2996();
+ o.userStepToStateFamilyNameMap = buildUnnamed2997();
o.windmillServiceEndpoint = "foo";
o.windmillServicePort = "foo";
}
@@ -3501,8 +3501,8 @@ buildStreamingConfigTask() {
checkStreamingConfigTask(api.StreamingConfigTask o) {
buildCounterStreamingConfigTask++;
if (buildCounterStreamingConfigTask < 3) {
- checkUnnamed3522(o.streamingComputationConfigs);
- checkUnnamed3523(o.userStepToStateFamilyNameMap);
+ checkUnnamed2996(o.streamingComputationConfigs);
+ checkUnnamed2997(o.userStepToStateFamilyNameMap);
unittest.expect(o.windmillServiceEndpoint, unittest.equals('foo'));
unittest.expect(o.windmillServicePort, unittest.equals('foo'));
}
@@ -3574,14 +3574,14 @@ checkStreamingStageLocation(api.StreamingStageLocation o) {
buildCounterStreamingStageLocation--;
}
-buildUnnamed3524() {
+buildUnnamed2998() {
var o = new core.List<core.String>();
o.add("foo");
o.add("foo");
return o;
}
-checkUnnamed3524(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'));
@@ -3592,7 +3592,7 @@ buildStringList() {
var o = new api.StringList();
buildCounterStringList++;
if (buildCounterStringList < 3) {
- o.elements = buildUnnamed3524();
+ o.elements = buildUnnamed2998();
}
buildCounterStringList--;
return o;
@@ -3601,19 +3601,19 @@ buildStringList() {
checkStringList(api.StringList o) {
buildCounterStringList++;
if (buildCounterStringList < 3) {
- checkUnnamed3524(o.elements);
+ checkUnnamed2998(o.elements);
}
buildCounterStringList--;
}
-buildUnnamed3525() {
+buildUnnamed2999() {
var o = new core.List<api.Parameter>();
o.add(buildParameter());
o.add(buildParameter());
return o;
}
-checkUnnamed3525(core.List<api.Parameter> o) {
+checkUnnamed2999(core.List<api.Parameter> o) {
unittest.expect(o, unittest.hasLength(2));
checkParameter(o[0]);
checkParameter(o[1]);
@@ -3626,7 +3626,7 @@ buildStructuredMessage() {
if (buildCounterStructuredMessage < 3) {
o.messageKey = "foo";
o.messageText = "foo";
- o.parameters = buildUnnamed3525();
+ o.parameters = buildUnnamed2999();
}
buildCounterStructuredMessage--;
return o;
@@ -3637,19 +3637,19 @@ checkStructuredMessage(api.StructuredMessage o) {
if (buildCounterStructuredMessage < 3) {
unittest.expect(o.messageKey, unittest.equals('foo'));
unittest.expect(o.messageText, unittest.equals('foo'));
- checkUnnamed3525(o.parameters);
+ checkUnnamed2999(o.parameters);
}
buildCounterStructuredMessage--;
}
-buildUnnamed3526() {
+buildUnnamed3000() {
var o = new core.List<core.String>();
o.add("foo");
o.add("foo");
return o;
}
-checkUnnamed3526(core.List<core.String> o) {
+checkUnnamed3000(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'));
@@ -3671,7 +3671,7 @@ buildTaskRunnerSettings() {
o.logDir = "foo";
o.logToSerialconsole = true;
o.logUploadLocation = "foo";
- o.oauthScopes = buildUnnamed3526();
+ o.oauthScopes = buildUnnamed3000();
o.parallelWorkerSettings = buildWorkerSettings();
o.streamingWorkerMainClass = "foo";
o.taskGroup = "foo";
@@ -3698,7 +3698,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'));
- checkUnnamed3526(o.oauthScopes);
+ checkUnnamed3000(o.oauthScopes);
checkWorkerSettings(o.parallelWorkerSettings);
unittest.expect(o.streamingWorkerMainClass, unittest.equals('foo'));
unittest.expect(o.taskGroup, unittest.equals('foo'));
@@ -3710,14 +3710,14 @@ checkTaskRunnerSettings(api.TaskRunnerSettings o) {
buildCounterTaskRunnerSettings--;
}
-buildUnnamed3527() {
+buildUnnamed3001() {
var o = new core.List<api.ParameterMetadata>();
o.add(buildParameterMetadata());
o.add(buildParameterMetadata());
return o;
}
-checkUnnamed3527(core.List<api.ParameterMetadata> o) {
+checkUnnamed3001(core.List<api.ParameterMetadata> o) {
unittest.expect(o, unittest.hasLength(2));
checkParameterMetadata(o[0]);
checkParameterMetadata(o[1]);
@@ -3728,10 +3728,9 @@ buildTemplateMetadata() {
var o = new api.TemplateMetadata();
buildCounterTemplateMetadata++;
if (buildCounterTemplateMetadata < 3) {
- o.bypassTempDirValidation = true;
o.description = "foo";
o.name = "foo";
- o.parameters = buildUnnamed3527();
+ o.parameters = buildUnnamed3001();
}
buildCounterTemplateMetadata--;
return o;
@@ -3740,48 +3739,47 @@ buildTemplateMetadata() {
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'));
- checkUnnamed3527(o.parameters);
+ checkUnnamed3001(o.parameters);
}
buildCounterTemplateMetadata--;
}
-buildUnnamed3528() {
+buildUnnamed3002() {
var o = new core.List<api.ComputationTopology>();
o.add(buildComputationTopology());
o.add(buildComputationTopology());
return o;
}
-checkUnnamed3528(core.List<api.ComputationTopology> o) {
+checkUnnamed3002(core.List<api.ComputationTopology> o) {
unittest.expect(o, unittest.hasLength(2));
checkComputationTopology(o[0]);
checkComputationTopology(o[1]);
}
-buildUnnamed3529() {
+buildUnnamed3003() {
var o = new core.List<api.DataDiskAssignment>();
o.add(buildDataDiskAssignment());
o.add(buildDataDiskAssignment());
return o;
}
-checkUnnamed3529(core.List<api.DataDiskAssignment> o) {
+checkUnnamed3003(core.List<api.DataDiskAssignment> o) {
unittest.expect(o, unittest.hasLength(2));
checkDataDiskAssignment(o[0]);
checkDataDiskAssignment(o[1]);
}
-buildUnnamed3530() {
+buildUnnamed3004() {
var o = new core.Map<core.String, core.String>();
o["x"] = "foo";
o["y"] = "foo";
return o;
}
-checkUnnamed3530(core.Map<core.String, core.String> o) {
+checkUnnamed3004(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'));
@@ -3792,11 +3790,11 @@ buildTopologyConfig() {
var o = new api.TopologyConfig();
buildCounterTopologyConfig++;
if (buildCounterTopologyConfig < 3) {
- o.computations = buildUnnamed3528();
- o.dataDiskAssignments = buildUnnamed3529();
+ o.computations = buildUnnamed3002();
+ o.dataDiskAssignments = buildUnnamed3003();
o.forwardingKeyBits = 42;
o.persistentStateVersion = 42;
- o.userStageToComputationNameMap = buildUnnamed3530();
+ o.userStageToComputationNameMap = buildUnnamed3004();
}
buildCounterTopologyConfig--;
return o;
@@ -3805,49 +3803,49 @@ buildTopologyConfig() {
checkTopologyConfig(api.TopologyConfig o) {
buildCounterTopologyConfig++;
if (buildCounterTopologyConfig < 3) {
- checkUnnamed3528(o.computations);
- checkUnnamed3529(o.dataDiskAssignments);
+ checkUnnamed3002(o.computations);
+ checkUnnamed3003(o.dataDiskAssignments);
unittest.expect(o.forwardingKeyBits, unittest.equals(42));
unittest.expect(o.persistentStateVersion, unittest.equals(42));
- checkUnnamed3530(o.userStageToComputationNameMap);
+ checkUnnamed3004(o.userStageToComputationNameMap);
}
buildCounterTopologyConfig--;
}
-buildUnnamed3531() {
+buildUnnamed3005() {
var o = new core.List<api.DisplayData>();
o.add(buildDisplayData());
o.add(buildDisplayData());
return o;
}
-checkUnnamed3531(core.List<api.DisplayData> o) {
+checkUnnamed3005(core.List<api.DisplayData> o) {
unittest.expect(o, unittest.hasLength(2));
checkDisplayData(o[0]);
checkDisplayData(o[1]);
}
-buildUnnamed3532() {
+buildUnnamed3006() {
var o = new core.List<core.String>();
o.add("foo");
o.add("foo");
return o;
}
-checkUnnamed3532(core.List<core.String> o) {
+checkUnnamed3006(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'));
}
-buildUnnamed3533() {
+buildUnnamed3007() {
var o = new core.List<core.String>();
o.add("foo");
o.add("foo");
return o;
}
-checkUnnamed3533(core.List<core.String> o) {
+checkUnnamed3007(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'));
@@ -3858,12 +3856,12 @@ buildTransformSummary() {
var o = new api.TransformSummary();
buildCounterTransformSummary++;
if (buildCounterTransformSummary < 3) {
- o.displayData = buildUnnamed3531();
+ o.displayData = buildUnnamed3005();
o.id = "foo";
- o.inputCollectionName = buildUnnamed3532();
+ o.inputCollectionName = buildUnnamed3006();
o.kind = "foo";
o.name = "foo";
- o.outputCollectionName = buildUnnamed3533();
+ o.outputCollectionName = buildUnnamed3007();
}
buildCounterTransformSummary--;
return o;
@@ -3872,24 +3870,24 @@ buildTransformSummary() {
checkTransformSummary(api.TransformSummary o) {
buildCounterTransformSummary++;
if (buildCounterTransformSummary < 3) {
- checkUnnamed3531(o.displayData);
+ checkUnnamed3005(o.displayData);
unittest.expect(o.id, unittest.equals('foo'));
- checkUnnamed3532(o.inputCollectionName);
+ checkUnnamed3006(o.inputCollectionName);
unittest.expect(o.kind, unittest.equals('foo'));
unittest.expect(o.name, unittest.equals('foo'));
- checkUnnamed3533(o.outputCollectionName);
+ checkUnnamed3007(o.outputCollectionName);
}
buildCounterTransformSummary--;
}
-buildUnnamed3534() {
+buildUnnamed3008() {
var o = new core.List<api.Package>();
o.add(buildPackage());
o.add(buildPackage());
return o;
}
-checkUnnamed3534(core.List<api.Package> o) {
+checkUnnamed3008(core.List<api.Package> o) {
unittest.expect(o, unittest.hasLength(2));
checkPackage(o[0]);
checkPackage(o[1]);
@@ -3906,7 +3904,7 @@ buildWorkItem() {
o.jobId = "foo";
o.leaseExpireTime = "foo";
o.mapTask = buildMapTask();
- o.packages = buildUnnamed3534();
+ o.packages = buildUnnamed3008();
o.projectId = "foo";
o.reportStatusInterval = "foo";
o.seqMapTask = buildSeqMapTask();
@@ -3929,7 +3927,7 @@ checkWorkItem(api.WorkItem o) {
unittest.expect(o.jobId, unittest.equals('foo'));
unittest.expect(o.leaseExpireTime, unittest.equals('foo'));
checkMapTask(o.mapTask);
- checkUnnamed3534(o.packages);
+ checkUnnamed3008(o.packages);
unittest.expect(o.projectId, unittest.equals('foo'));
unittest.expect(o.reportStatusInterval, unittest.equals('foo'));
checkSeqMapTask(o.seqMapTask);
@@ -3942,27 +3940,27 @@ checkWorkItem(api.WorkItem o) {
buildCounterWorkItem--;
}
-buildUnnamed3535() {
+buildUnnamed3009() {
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;
}
-checkUnnamed3535(core.Map<core.String, core.Object> o) {
+checkUnnamed3009(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'));
}
-buildUnnamed3536() {
+buildUnnamed3010() {
var o = new core.List<api.MetricShortId>();
o.add(buildMetricShortId());
o.add(buildMetricShortId());
return o;
}
-checkUnnamed3536(core.List<api.MetricShortId> o) {
+checkUnnamed3010(core.List<api.MetricShortId> o) {
unittest.expect(o, unittest.hasLength(2));
checkMetricShortId(o[0]);
checkMetricShortId(o[1]);
@@ -3973,9 +3971,9 @@ buildWorkItemServiceState() {
var o = new api.WorkItemServiceState();
buildCounterWorkItemServiceState++;
if (buildCounterWorkItemServiceState < 3) {
- o.harnessData = buildUnnamed3535();
+ o.harnessData = buildUnnamed3009();
o.leaseExpireTime = "foo";
- o.metricShortId = buildUnnamed3536();
+ o.metricShortId = buildUnnamed3010();
o.nextReportIndex = "foo";
o.reportStatusInterval = "foo";
o.splitRequest = buildApproximateSplitRequest();
@@ -3989,9 +3987,9 @@ buildWorkItemServiceState() {
checkWorkItemServiceState(api.WorkItemServiceState o) {
buildCounterWorkItemServiceState++;
if (buildCounterWorkItemServiceState < 3) {
- checkUnnamed3535(o.harnessData);
+ checkUnnamed3009(o.harnessData);
unittest.expect(o.leaseExpireTime, unittest.equals('foo'));
- checkUnnamed3536(o.metricShortId);
+ checkUnnamed3010(o.metricShortId);
unittest.expect(o.nextReportIndex, unittest.equals('foo'));
unittest.expect(o.reportStatusInterval, unittest.equals('foo'));
checkApproximateSplitRequest(o.splitRequest);
@@ -4001,40 +3999,40 @@ checkWorkItemServiceState(api.WorkItemServiceState o) {
buildCounterWorkItemServiceState--;
}
-buildUnnamed3537() {
+buildUnnamed3011() {
var o = new core.List<api.CounterUpdate>();
o.add(buildCounterUpdate());
o.add(buildCounterUpdate());
return o;
}
-checkUnnamed3537(core.List<api.CounterUpdate> o) {
+checkUnnamed3011(core.List<api.CounterUpdate> o) {
unittest.expect(o, unittest.hasLength(2));
checkCounterUpdate(o[0]);
checkCounterUpdate(o[1]);
}
-buildUnnamed3538() {
+buildUnnamed3012() {
var o = new core.List<api.Status>();
o.add(buildStatus());
o.add(buildStatus());
return o;
}
-checkUnnamed3538(core.List<api.Status> o) {
+checkUnnamed3012(core.List<api.Status> o) {
unittest.expect(o, unittest.hasLength(2));
checkStatus(o[0]);
checkStatus(o[1]);
}
-buildUnnamed3539() {
+buildUnnamed3013() {
var o = new core.List<api.MetricUpdate>();
o.add(buildMetricUpdate());
o.add(buildMetricUpdate());
return o;
}
-checkUnnamed3539(core.List<api.MetricUpdate> o) {
+checkUnnamed3013(core.List<api.MetricUpdate> o) {
unittest.expect(o, unittest.hasLength(2));
checkMetricUpdate(o[0]);
checkMetricUpdate(o[1]);
@@ -4046,10 +4044,10 @@ buildWorkItemStatus() {
buildCounterWorkItemStatus++;
if (buildCounterWorkItemStatus < 3) {
o.completed = true;
- o.counterUpdates = buildUnnamed3537();
+ o.counterUpdates = buildUnnamed3011();
o.dynamicSourceSplit = buildDynamicSourceSplit();
- o.errors = buildUnnamed3538();
- o.metricUpdates = buildUnnamed3539();
+ o.errors = buildUnnamed3012();
+ o.metricUpdates = buildUnnamed3013();
o.progress = buildApproximateProgress();
o.reportIndex = "foo";
o.reportedProgress = buildApproximateReportedProgress();
@@ -4067,10 +4065,10 @@ checkWorkItemStatus(api.WorkItemStatus o) {
buildCounterWorkItemStatus++;
if (buildCounterWorkItemStatus < 3) {
unittest.expect(o.completed, unittest.isTrue);
- checkUnnamed3537(o.counterUpdates);
+ checkUnnamed3011(o.counterUpdates);
checkDynamicSourceSplit(o.dynamicSourceSplit);
- checkUnnamed3538(o.errors);
- checkUnnamed3539(o.metricUpdates);
+ checkUnnamed3012(o.errors);
+ checkUnnamed3013(o.metricUpdates);
checkApproximateProgress(o.progress);
unittest.expect(o.reportIndex, unittest.equals('foo'));
checkApproximateReportedProgress(o.reportedProgress);
@@ -4083,30 +4081,30 @@ checkWorkItemStatus(api.WorkItemStatus o) {
buildCounterWorkItemStatus--;
}
-buildUnnamed3540() {
+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;
}
-checkUnnamed3540(core.Map<core.String, core.Object> o) {
+checkUnnamed3014(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'));
}
-buildUnnamed3541() {
+buildUnnamed3015() {
var o = new core.List<core.Map<core.String, core.Object>>();
- o.add(buildUnnamed3540());
- o.add(buildUnnamed3540());
+ o.add(buildUnnamed3014());
+ o.add(buildUnnamed3014());
return o;
}
-checkUnnamed3541(core.List<core.Map<core.String, core.Object>> o) {
+checkUnnamed3015(core.List<core.Map<core.String, core.Object>> o) {
unittest.expect(o, unittest.hasLength(2));
- checkUnnamed3540(o[0]);
- checkUnnamed3540(o[1]);
+ checkUnnamed3014(o[0]);
+ checkUnnamed3014(o[1]);
}
core.int buildCounterWorkerHealthReport = 0;
@@ -4114,7 +4112,7 @@ buildWorkerHealthReport() {
var o = new api.WorkerHealthReport();
buildCounterWorkerHealthReport++;
if (buildCounterWorkerHealthReport < 3) {
- o.pods = buildUnnamed3541();
+ o.pods = buildUnnamed3015();
o.reportInterval = "foo";
o.vmIsHealthy = true;
o.vmStartupTime = "foo";
@@ -4126,7 +4124,7 @@ buildWorkerHealthReport() {
checkWorkerHealthReport(api.WorkerHealthReport o) {
buildCounterWorkerHealthReport++;
if (buildCounterWorkerHealthReport < 3) {
- checkUnnamed3541(o.pods);
+ checkUnnamed3015(o.pods);
unittest.expect(o.reportInterval, unittest.equals('foo'));
unittest.expect(o.vmIsHealthy, unittest.isTrue);
unittest.expect(o.vmStartupTime, unittest.equals('foo'));
@@ -4153,14 +4151,14 @@ checkWorkerHealthReportResponse(api.WorkerHealthReportResponse o) {
buildCounterWorkerHealthReportResponse--;
}
-buildUnnamed3542() {
+buildUnnamed3016() {
var o = new core.Map<core.String, core.String>();
o["x"] = "foo";
o["y"] = "foo";
return o;
}
-checkUnnamed3542(core.Map<core.String, core.String> o) {
+checkUnnamed3016(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'));
@@ -4171,7 +4169,7 @@ buildWorkerMessage() {
var o = new api.WorkerMessage();
buildCounterWorkerMessage++;
if (buildCounterWorkerMessage < 3) {
- o.labels = buildUnnamed3542();
+ o.labels = buildUnnamed3016();
o.time = "foo";
o.workerHealthReport = buildWorkerHealthReport();
o.workerMessageCode = buildWorkerMessageCode();
@@ -4184,7 +4182,7 @@ buildWorkerMessage() {
checkWorkerMessage(api.WorkerMessage o) {
buildCounterWorkerMessage++;
if (buildCounterWorkerMessage < 3) {
- checkUnnamed3542(o.labels);
+ checkUnnamed3016(o.labels);
unittest.expect(o.time, unittest.equals('foo'));
checkWorkerHealthReport(o.workerHealthReport);
checkWorkerMessageCode(o.workerMessageCode);
@@ -4193,14 +4191,14 @@ checkWorkerMessage(api.WorkerMessage o) {
buildCounterWorkerMessage--;
}
-buildUnnamed3543() {
+buildUnnamed3017() {
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;
}
-checkUnnamed3543(core.Map<core.String, core.Object> o) {
+checkUnnamed3017(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'));
@@ -4212,7 +4210,7 @@ buildWorkerMessageCode() {
buildCounterWorkerMessageCode++;
if (buildCounterWorkerMessageCode < 3) {
o.code = "foo";
- o.parameters = buildUnnamed3543();
+ o.parameters = buildUnnamed3017();
}
buildCounterWorkerMessageCode--;
return o;
@@ -4222,7 +4220,7 @@ checkWorkerMessageCode(api.WorkerMessageCode o) {
buildCounterWorkerMessageCode++;
if (buildCounterWorkerMessageCode < 3) {
unittest.expect(o.code, unittest.equals('foo'));
- checkUnnamed3543(o.parameters);
+ checkUnnamed3017(o.parameters);
}
buildCounterWorkerMessageCode--;
}
@@ -4248,53 +4246,53 @@ checkWorkerMessageResponse(api.WorkerMessageResponse o) {
buildCounterWorkerMessageResponse--;
}
-buildUnnamed3544() {
+buildUnnamed3018() {
var o = new core.List<api.Disk>();
o.add(buildDisk());
o.add(buildDisk());
return o;
}
-checkUnnamed3544(core.List<api.Disk> o) {
+checkUnnamed3018(core.List<api.Disk> o) {
unittest.expect(o, unittest.hasLength(2));
checkDisk(o[0]);
checkDisk(o[1]);
}
-buildUnnamed3545() {
+buildUnnamed3019() {
var o = new core.Map<core.String, core.String>();
o["x"] = "foo";
o["y"] = "foo";
return o;
}
-checkUnnamed3545(core.Map<core.String, core.String> o) {
+checkUnnamed3019(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'));
}
-buildUnnamed3546() {
+buildUnnamed3020() {
var o = new core.List<api.Package>();
o.add(buildPackage());
o.add(buildPackage());
return o;
}
-checkUnnamed3546(core.List<api.Package> o) {
+checkUnnamed3020(core.List<api.Package> o) {
unittest.expect(o, unittest.hasLength(2));
checkPackage(o[0]);
checkPackage(o[1]);
}
-buildUnnamed3547() {
+buildUnnamed3021() {
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;
}
-checkUnnamed3547(core.Map<core.String, core.Object> o) {
+checkUnnamed3021(core.Map<core.String, core.Object> o) {
unittest.expect(o, unittest.hasLength(2));
var casted49 = (o["x"]) as core.Map; unittest.expect(casted49, unittest.hasLength(3)); unittest.expect(casted49["list"], unittest.equals([1, 2, 3])); unittest.expect(casted49["bool"], unittest.equals(true)); unittest.expect(casted49["string"], unittest.equals('foo'));
var casted50 = (o["y"]) as core.Map; unittest.expect(casted50, unittest.hasLength(3)); unittest.expect(casted50["list"], unittest.equals([1, 2, 3])); unittest.expect(casted50["bool"], unittest.equals(true)); unittest.expect(casted50["string"], unittest.equals('foo'));
@@ -4306,7 +4304,7 @@ buildWorkerPool() {
buildCounterWorkerPool++;
if (buildCounterWorkerPool < 3) {
o.autoscalingSettings = buildAutoscalingSettings();
- o.dataDisks = buildUnnamed3544();
+ o.dataDisks = buildUnnamed3018();
o.defaultPackageSet = "foo";
o.diskSizeGb = 42;
o.diskSourceImage = "foo";
@@ -4314,13 +4312,13 @@ buildWorkerPool() {
o.ipConfiguration = "foo";
o.kind = "foo";
o.machineType = "foo";
- o.metadata = buildUnnamed3545();
+ o.metadata = buildUnnamed3019();
o.network = "foo";
o.numThreadsPerWorker = 42;
o.numWorkers = 42;
o.onHostMaintenance = "foo";
- o.packages = buildUnnamed3546();
- o.poolArgs = buildUnnamed3547();
+ o.packages = buildUnnamed3020();
+ o.poolArgs = buildUnnamed3021();
o.subnetwork = "foo";
o.taskrunnerSettings = buildTaskRunnerSettings();
o.teardownPolicy = "foo";
@@ -4335,7 +4333,7 @@ checkWorkerPool(api.WorkerPool o) {
buildCounterWorkerPool++;
if (buildCounterWorkerPool < 3) {
checkAutoscalingSettings(o.autoscalingSettings);
- checkUnnamed3544(o.dataDisks);
+ checkUnnamed3018(o.dataDisks);
unittest.expect(o.defaultPackageSet, unittest.equals('foo'));
unittest.expect(o.diskSizeGb, unittest.equals(42));
unittest.expect(o.diskSourceImage, unittest.equals('foo'));
@@ -4343,13 +4341,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'));
- checkUnnamed3545(o.metadata);
+ checkUnnamed3019(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'));
- checkUnnamed3546(o.packages);
- checkUnnamed3547(o.poolArgs);
+ checkUnnamed3020(o.packages);
+ checkUnnamed3021(o.poolArgs);
unittest.expect(o.subnetwork, unittest.equals('foo'));
checkTaskRunnerSettings(o.taskrunnerSettings);
unittest.expect(o.teardownPolicy, unittest.equals('foo'));
@@ -5525,7 +5523,7 @@ main() {
api.ProjectsResourceApi res = new api.DataflowApi(mock).projects;
var arg_request = buildSendWorkerMessagesRequest();
var arg_projectId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.SendWorkerMessagesRequest.fromJson(json);
checkSendWorkerMessagesRequest(obj);
@@ -5569,7 +5567,7 @@ main() {
var resp = convert.JSON.encode(buildSendWorkerMessagesResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.workerMessages(arg_request, arg_projectId).then(unittest.expectAsync(((api.SendWorkerMessagesResponse response) {
+ res.workerMessages(arg_request, arg_projectId).then(unittest.expectAsync1(((api.SendWorkerMessagesResponse response) {
checkSendWorkerMessagesResponse(response);
})));
});
@@ -5587,7 +5585,7 @@ main() {
var arg_view = "foo";
var arg_location = "foo";
var arg_replaceJobId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.Job.fromJson(json);
checkJob(obj);
@@ -5634,7 +5632,7 @@ main() {
var resp = convert.JSON.encode(buildJob());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.create(arg_request, arg_projectId, view: arg_view, location: arg_location, replaceJobId: arg_replaceJobId).then(unittest.expectAsync(((api.Job response) {
+ res.create(arg_request, arg_projectId, view: arg_view, location: arg_location, replaceJobId: arg_replaceJobId).then(unittest.expectAsync1(((api.Job response) {
checkJob(response);
})));
});
@@ -5647,7 +5645,7 @@ main() {
var arg_jobId = "foo";
var arg_view = "foo";
var arg_location = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var path = (req.url).path;
var pathOffset = 0;
var index;
@@ -5693,7 +5691,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, view: arg_view, location: arg_location).then(unittest.expectAsync1(((api.Job response) {
checkJob(response);
})));
});
@@ -5704,9 +5702,9 @@ main() {
api.ProjectsJobsResourceApi res = new api.DataflowApi(mock).projects.jobs;
var arg_projectId = "foo";
var arg_jobId = "foo";
- var arg_location = "foo";
var arg_startTime = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ var arg_location = "foo";
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var path = (req.url).path;
var pathOffset = 0;
var index;
@@ -5746,8 +5744,8 @@ main() {
addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
}
}
- unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
unittest.expect(queryMap["startTime"].first, unittest.equals(arg_startTime));
+ unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
var h = {
@@ -5756,7 +5754,7 @@ main() {
var resp = convert.JSON.encode(buildJobMetrics());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.getMetrics(arg_projectId, arg_jobId, location: arg_location, startTime: arg_startTime).then(unittest.expectAsync(((api.JobMetrics response) {
+ res.getMetrics(arg_projectId, arg_jobId, startTime: arg_startTime, location: arg_location).then(unittest.expectAsync1(((api.JobMetrics response) {
checkJobMetrics(response);
})));
});
@@ -5766,12 +5764,12 @@ main() {
var mock = new HttpServerMock();
api.ProjectsJobsResourceApi res = new api.DataflowApi(mock).projects.jobs;
var arg_projectId = "foo";
- var arg_view = "foo";
- var arg_filter = "foo";
var arg_location = "foo";
var arg_pageToken = "foo";
var arg_pageSize = 42;
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ var arg_view = "foo";
+ var arg_filter = "foo";
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var path = (req.url).path;
var pathOffset = 0;
var index;
@@ -5804,11 +5802,11 @@ main() {
addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
}
}
- unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
- unittest.expect(queryMap["filter"].first, unittest.equals(arg_filter));
unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
+ unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
+ unittest.expect(queryMap["filter"].first, unittest.equals(arg_filter));
var h = {
@@ -5817,7 +5815,7 @@ main() {
var resp = convert.JSON.encode(buildListJobsResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.list(arg_projectId, view: arg_view, filter: arg_filter, location: arg_location, pageToken: arg_pageToken, pageSize: arg_pageSize).then(unittest.expectAsync(((api.ListJobsResponse response) {
+ res.list(arg_projectId, location: arg_location, pageToken: arg_pageToken, pageSize: arg_pageSize, view: arg_view, filter: arg_filter).then(unittest.expectAsync1(((api.ListJobsResponse response) {
checkListJobsResponse(response);
})));
});
@@ -5830,7 +5828,7 @@ main() {
var arg_projectId = "foo";
var arg_jobId = "foo";
var arg_location = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.Job.fromJson(json);
checkJob(obj);
@@ -5878,7 +5876,7 @@ main() {
var resp = convert.JSON.encode(buildJob());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.update(arg_request, arg_projectId, arg_jobId, location: arg_location).then(unittest.expectAsync(((api.Job response) {
+ res.update(arg_request, arg_projectId, arg_jobId, location: arg_location).then(unittest.expectAsync1(((api.Job response) {
checkJob(response);
})));
});
@@ -5894,7 +5892,7 @@ main() {
var arg_request = buildGetDebugConfigRequest();
var arg_projectId = "foo";
var arg_jobId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.GetDebugConfigRequest.fromJson(json);
checkGetDebugConfigRequest(obj);
@@ -5945,7 +5943,7 @@ main() {
var resp = convert.JSON.encode(buildGetDebugConfigResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.getConfig(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.GetDebugConfigResponse response) {
+ res.getConfig(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync1(((api.GetDebugConfigResponse response) {
checkGetDebugConfigResponse(response);
})));
});
@@ -5957,7 +5955,7 @@ main() {
var arg_request = buildSendDebugCaptureRequest();
var arg_projectId = "foo";
var arg_jobId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.SendDebugCaptureRequest.fromJson(json);
checkSendDebugCaptureRequest(obj);
@@ -6008,7 +6006,7 @@ main() {
var resp = convert.JSON.encode(buildSendDebugCaptureResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.sendCapture(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.SendDebugCaptureResponse response) {
+ res.sendCapture(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync1(((api.SendDebugCaptureResponse response) {
checkSendDebugCaptureResponse(response);
})));
});
@@ -6023,13 +6021,13 @@ main() {
api.ProjectsJobsMessagesResourceApi res = new api.DataflowApi(mock).projects.jobs.messages;
var arg_projectId = "foo";
var arg_jobId = "foo";
+ var arg_pageSize = 42;
var arg_minimumImportance = "foo";
- var arg_endTime = "foo";
var arg_location = "foo";
- var arg_pageToken = "foo";
+ var arg_endTime = "foo";
var arg_startTime = "foo";
- var arg_pageSize = 42;
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ var arg_pageToken = "foo";
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var path = (req.url).path;
var pathOffset = 0;
var index;
@@ -6069,12 +6067,12 @@ main() {
addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
}
}
+ unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
unittest.expect(queryMap["minimumImportance"].first, unittest.equals(arg_minimumImportance));
- unittest.expect(queryMap["endTime"].first, unittest.equals(arg_endTime));
unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
- unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
+ unittest.expect(queryMap["endTime"].first, unittest.equals(arg_endTime));
unittest.expect(queryMap["startTime"].first, unittest.equals(arg_startTime));
- unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
+ unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
var h = {
@@ -6083,7 +6081,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, endTime: arg_endTime, location: arg_location, pageToken: arg_pageToken, startTime: arg_startTime, pageSize: arg_pageSize).then(unittest.expectAsync(((api.ListJobMessagesResponse response) {
+ res.list(arg_projectId, arg_jobId, pageSize: arg_pageSize, minimumImportance: arg_minimumImportance, location: arg_location, endTime: arg_endTime, startTime: arg_startTime, pageToken: arg_pageToken).then(unittest.expectAsync1(((api.ListJobMessagesResponse response) {
checkListJobMessagesResponse(response);
})));
});
@@ -6099,7 +6097,7 @@ main() {
var arg_request = buildLeaseWorkItemRequest();
var arg_projectId = "foo";
var arg_jobId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.LeaseWorkItemRequest.fromJson(json);
checkLeaseWorkItemRequest(obj);
@@ -6150,7 +6148,7 @@ main() {
var resp = convert.JSON.encode(buildLeaseWorkItemResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.lease(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.LeaseWorkItemResponse response) {
+ res.lease(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync1(((api.LeaseWorkItemResponse response) {
checkLeaseWorkItemResponse(response);
})));
});
@@ -6162,7 +6160,7 @@ main() {
var arg_request = buildReportWorkItemStatusRequest();
var arg_projectId = "foo";
var arg_jobId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.ReportWorkItemStatusRequest.fromJson(json);
checkReportWorkItemStatusRequest(obj);
@@ -6213,7 +6211,7 @@ main() {
var resp = convert.JSON.encode(buildReportWorkItemStatusResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.reportStatus(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.ReportWorkItemStatusResponse response) {
+ res.reportStatus(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync1(((api.ReportWorkItemStatusResponse response) {
checkReportWorkItemStatusResponse(response);
})));
});
@@ -6229,7 +6227,7 @@ main() {
var arg_request = buildSendWorkerMessagesRequest();
var arg_projectId = "foo";
var arg_location = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.SendWorkerMessagesRequest.fromJson(json);
checkSendWorkerMessagesRequest(obj);
@@ -6280,7 +6278,7 @@ main() {
var resp = convert.JSON.encode(buildSendWorkerMessagesResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.workerMessages(arg_request, arg_projectId, arg_location).then(unittest.expectAsync(((api.SendWorkerMessagesResponse response) {
+ res.workerMessages(arg_request, arg_projectId, arg_location).then(unittest.expectAsync1(((api.SendWorkerMessagesResponse response) {
checkSendWorkerMessagesResponse(response);
})));
});
@@ -6298,7 +6296,7 @@ main() {
var arg_location = "foo";
var arg_view = "foo";
var arg_replaceJobId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.Job.fromJson(json);
checkJob(obj);
@@ -6351,7 +6349,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, view: arg_view, replaceJobId: arg_replaceJobId).then(unittest.expectAsync1(((api.Job response) {
checkJob(response);
})));
});
@@ -6364,7 +6362,7 @@ main() {
var arg_location = "foo";
var arg_jobId = "foo";
var arg_view = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var path = (req.url).path;
var pathOffset = 0;
var index;
@@ -6416,7 +6414,7 @@ main() {
var resp = convert.JSON.encode(buildJob());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.get(arg_projectId, arg_location, arg_jobId, view: arg_view).then(unittest.expectAsync(((api.Job response) {
+ res.get(arg_projectId, arg_location, arg_jobId, view: arg_view).then(unittest.expectAsync1(((api.Job response) {
checkJob(response);
})));
});
@@ -6429,7 +6427,7 @@ main() {
var arg_location = "foo";
var arg_jobId = "foo";
var arg_startTime = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var path = (req.url).path;
var pathOffset = 0;
var index;
@@ -6485,7 +6483,7 @@ main() {
var resp = convert.JSON.encode(buildJobMetrics());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.getMetrics(arg_projectId, arg_location, arg_jobId, startTime: arg_startTime).then(unittest.expectAsync(((api.JobMetrics response) {
+ res.getMetrics(arg_projectId, arg_location, arg_jobId, startTime: arg_startTime).then(unittest.expectAsync1(((api.JobMetrics response) {
checkJobMetrics(response);
})));
});
@@ -6496,11 +6494,11 @@ main() {
api.ProjectsLocationsJobsResourceApi res = new api.DataflowApi(mock).projects.locations.jobs;
var arg_projectId = "foo";
var arg_location = "foo";
- var arg_filter = "foo";
var arg_pageToken = "foo";
var arg_pageSize = 42;
var arg_view = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ var arg_filter = "foo";
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var path = (req.url).path;
var pathOffset = 0;
var index;
@@ -6540,10 +6538,10 @@ main() {
addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
}
}
- unittest.expect(queryMap["filter"].first, unittest.equals(arg_filter));
unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
+ unittest.expect(queryMap["filter"].first, unittest.equals(arg_filter));
var h = {
@@ -6552,7 +6550,7 @@ main() {
var resp = convert.JSON.encode(buildListJobsResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.list(arg_projectId, arg_location, filter: arg_filter, pageToken: arg_pageToken, pageSize: arg_pageSize, view: arg_view).then(unittest.expectAsync(((api.ListJobsResponse response) {
+ res.list(arg_projectId, arg_location, pageToken: arg_pageToken, pageSize: arg_pageSize, view: arg_view, filter: arg_filter).then(unittest.expectAsync1(((api.ListJobsResponse response) {
checkListJobsResponse(response);
})));
});
@@ -6565,7 +6563,7 @@ main() {
var arg_projectId = "foo";
var arg_location = "foo";
var arg_jobId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.Job.fromJson(json);
checkJob(obj);
@@ -6619,7 +6617,7 @@ main() {
var resp = convert.JSON.encode(buildJob());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.update(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync(((api.Job response) {
+ res.update(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync1(((api.Job response) {
checkJob(response);
})));
});
@@ -6636,7 +6634,7 @@ main() {
var arg_projectId = "foo";
var arg_location = "foo";
var arg_jobId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.GetDebugConfigRequest.fromJson(json);
checkGetDebugConfigRequest(obj);
@@ -6694,7 +6692,7 @@ main() {
var resp = convert.JSON.encode(buildGetDebugConfigResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.getConfig(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync(((api.GetDebugConfigResponse response) {
+ res.getConfig(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync1(((api.GetDebugConfigResponse response) {
checkGetDebugConfigResponse(response);
})));
});
@@ -6707,7 +6705,7 @@ main() {
var arg_projectId = "foo";
var arg_location = "foo";
var arg_jobId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.SendDebugCaptureRequest.fromJson(json);
checkSendDebugCaptureRequest(obj);
@@ -6765,7 +6763,7 @@ main() {
var resp = convert.JSON.encode(buildSendDebugCaptureResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.sendCapture(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync(((api.SendDebugCaptureResponse response) {
+ res.sendCapture(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync1(((api.SendDebugCaptureResponse response) {
checkSendDebugCaptureResponse(response);
})));
});
@@ -6781,12 +6779,12 @@ main() {
var arg_projectId = "foo";
var arg_location = "foo";
var arg_jobId = "foo";
- var arg_endTime = "foo";
var arg_startTime = "foo";
var arg_pageToken = "foo";
var arg_pageSize = 42;
var arg_minimumImportance = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ var arg_endTime = "foo";
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var path = (req.url).path;
var pathOffset = 0;
var index;
@@ -6833,11 +6831,11 @@ main() {
addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
}
}
- unittest.expect(queryMap["endTime"].first, unittest.equals(arg_endTime));
unittest.expect(queryMap["startTime"].first, unittest.equals(arg_startTime));
unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
unittest.expect(queryMap["minimumImportance"].first, unittest.equals(arg_minimumImportance));
+ unittest.expect(queryMap["endTime"].first, unittest.equals(arg_endTime));
var h = {
@@ -6846,7 +6844,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, startTime: arg_startTime, pageToken: arg_pageToken, pageSize: arg_pageSize, minimumImportance: arg_minimumImportance, endTime: arg_endTime).then(unittest.expectAsync1(((api.ListJobMessagesResponse response) {
checkListJobMessagesResponse(response);
})));
});
@@ -6863,7 +6861,7 @@ main() {
var arg_projectId = "foo";
var arg_location = "foo";
var arg_jobId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.LeaseWorkItemRequest.fromJson(json);
checkLeaseWorkItemRequest(obj);
@@ -6921,7 +6919,7 @@ main() {
var resp = convert.JSON.encode(buildLeaseWorkItemResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.lease(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync(((api.LeaseWorkItemResponse response) {
+ res.lease(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync1(((api.LeaseWorkItemResponse response) {
checkLeaseWorkItemResponse(response);
})));
});
@@ -6934,7 +6932,7 @@ main() {
var arg_projectId = "foo";
var arg_location = "foo";
var arg_jobId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.ReportWorkItemStatusRequest.fromJson(json);
checkReportWorkItemStatusRequest(obj);
@@ -6992,7 +6990,7 @@ main() {
var resp = convert.JSON.encode(buildReportWorkItemStatusResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.reportStatus(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync(((api.ReportWorkItemStatusResponse response) {
+ res.reportStatus(arg_request, arg_projectId, arg_location, arg_jobId).then(unittest.expectAsync1(((api.ReportWorkItemStatusResponse response) {
checkReportWorkItemStatusResponse(response);
})));
});
@@ -7008,7 +7006,7 @@ main() {
var arg_request = buildCreateJobFromTemplateRequest();
var arg_projectId = "foo";
var arg_location = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.CreateJobFromTemplateRequest.fromJson(json);
checkCreateJobFromTemplateRequest(obj);
@@ -7059,7 +7057,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).then(unittest.expectAsync(((api.Job response) {
+ res.create(arg_request, arg_projectId, arg_location).then(unittest.expectAsync1(((api.Job response) {
checkJob(response);
})));
});
@@ -7072,7 +7070,7 @@ main() {
var arg_location = "foo";
var arg_view = "foo";
var arg_gcsPath = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var path = (req.url).path;
var pathOffset = 0;
var index;
@@ -7122,7 +7120,7 @@ main() {
var resp = convert.JSON.encode(buildGetTemplateResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.get(arg_projectId, arg_location, view: arg_view, gcsPath: arg_gcsPath).then(unittest.expectAsync(((api.GetTemplateResponse response) {
+ res.get(arg_projectId, arg_location, view: arg_view, gcsPath: arg_gcsPath).then(unittest.expectAsync1(((api.GetTemplateResponse response) {
checkGetTemplateResponse(response);
})));
});
@@ -7134,9 +7132,9 @@ main() {
var arg_request = buildLaunchTemplateParameters();
var arg_projectId = "foo";
var arg_location = "foo";
- var arg_validateOnly = true;
var arg_gcsPath = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ var arg_validateOnly = true;
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.LaunchTemplateParameters.fromJson(json);
checkLaunchTemplateParameters(obj);
@@ -7179,8 +7177,8 @@ main() {
addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
}
}
- unittest.expect(queryMap["validateOnly"].first, unittest.equals("$arg_validateOnly"));
unittest.expect(queryMap["gcsPath"].first, unittest.equals(arg_gcsPath));
+ unittest.expect(queryMap["validateOnly"].first, unittest.equals("$arg_validateOnly"));
var h = {
@@ -7189,7 +7187,7 @@ main() {
var resp = convert.JSON.encode(buildLaunchTemplateResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.launch(arg_request, arg_projectId, arg_location, validateOnly: arg_validateOnly, gcsPath: arg_gcsPath).then(unittest.expectAsync(((api.LaunchTemplateResponse response) {
+ res.launch(arg_request, arg_projectId, arg_location, gcsPath: arg_gcsPath, validateOnly: arg_validateOnly).then(unittest.expectAsync1(((api.LaunchTemplateResponse response) {
checkLaunchTemplateResponse(response);
})));
});
@@ -7204,7 +7202,7 @@ main() {
api.ProjectsTemplatesResourceApi res = new api.DataflowApi(mock).projects.templates;
var arg_request = buildCreateJobFromTemplateRequest();
var arg_projectId = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.CreateJobFromTemplateRequest.fromJson(json);
checkCreateJobFromTemplateRequest(obj);
@@ -7248,7 +7246,7 @@ main() {
var resp = convert.JSON.encode(buildJob());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.create(arg_request, arg_projectId).then(unittest.expectAsync(((api.Job response) {
+ res.create(arg_request, arg_projectId).then(unittest.expectAsync1(((api.Job response) {
checkJob(response);
})));
});
@@ -7258,10 +7256,10 @@ main() {
var mock = new HttpServerMock();
api.ProjectsTemplatesResourceApi res = new api.DataflowApi(mock).projects.templates;
var arg_projectId = "foo";
+ var arg_location = "foo";
var arg_view = "foo";
var arg_gcsPath = "foo";
- var arg_location = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var path = (req.url).path;
var pathOffset = 0;
var index;
@@ -7294,9 +7292,9 @@ main() {
addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
}
}
+ unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
unittest.expect(queryMap["view"].first, unittest.equals(arg_view));
unittest.expect(queryMap["gcsPath"].first, unittest.equals(arg_gcsPath));
- unittest.expect(queryMap["location"].first, unittest.equals(arg_location));
var h = {
@@ -7305,7 +7303,7 @@ main() {
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, location: arg_location).then(unittest.expectAsync(((api.GetTemplateResponse response) {
+ res.get(arg_projectId, location: arg_location, view: arg_view, gcsPath: arg_gcsPath).then(unittest.expectAsync1(((api.GetTemplateResponse response) {
checkGetTemplateResponse(response);
})));
});
@@ -7319,7 +7317,7 @@ main() {
var arg_location = "foo";
var arg_validateOnly = true;
var arg_gcsPath = "foo";
- mock.register(unittest.expectAsync((http.BaseRequest req, json) {
+ mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
var obj = new api.LaunchTemplateParameters.fromJson(json);
checkLaunchTemplateParameters(obj);
@@ -7366,7 +7364,7 @@ main() {
var resp = convert.JSON.encode(buildLaunchTemplateResponse());
return new async.Future.value(stringResponse(200, h, resp));
}), true);
- res.launch(arg_request, arg_projectId, location: arg_location, validateOnly: arg_validateOnly, gcsPath: arg_gcsPath).then(unittest.expectAsync(((api.LaunchTemplateResponse response) {
+ res.launch(arg_request, arg_projectId, location: arg_location, validateOnly: arg_validateOnly, gcsPath: arg_gcsPath).then(unittest.expectAsync1(((api.LaunchTemplateResponse response) {
checkLaunchTemplateResponse(response);
})));
});

Powered by Google App Engine
This is Rietveld 408576698