| Index: generated/googleapis_beta/test/dataflow/v1beta3_test.dart
|
| diff --git a/generated/googleapis_beta/test/dataflow/v1beta3_test.dart b/generated/googleapis_beta/test/dataflow/v1beta3_test.dart
|
| index e5f58d46b7a4b5a569d73883c21a742e15a4cb95..c92e46e1f6455aacb8e45cab7c0573fbacdfaf51 100644
|
| --- a/generated/googleapis_beta/test/dataflow/v1beta3_test.dart
|
| +++ b/generated/googleapis_beta/test/dataflow/v1beta3_test.dart
|
| @@ -8,13 +8,48 @@ 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:googleapis_beta/common/common.dart' as common;
|
| -import 'package:googleapis_beta/src/common_internal.dart' as common_internal;
|
| -import '../common/common_internal_test.dart' as common_test;
|
|
|
| import 'package:googleapis_beta/dataflow/v1beta3.dart' as api;
|
|
|
| +class HttpServerMock extends http.BaseClient {
|
| + core.Function _callback;
|
| + core.bool _expectJson;
|
| +
|
| + void register(core.Function callback, core.bool expectJson) {
|
| + _callback = callback;
|
| + _expectJson = expectJson;
|
| + }
|
| +
|
| + async.Future<http.StreamedResponse> send(http.BaseRequest request) {
|
| + if (_expectJson) {
|
| + return request.finalize()
|
| + .transform(convert.UTF8.decoder)
|
| + .join('')
|
| + .then((core.String jsonString) {
|
| + if (jsonString.isEmpty) {
|
| + return _callback(request, null);
|
| + } else {
|
| + return _callback(request, convert.JSON.decode(jsonString));
|
| + }
|
| + });
|
| + } else {
|
| + var stream = request.finalize();
|
| + if (stream == null) {
|
| + return _callback(request, []);
|
| + } else {
|
| + return stream.toBytes().then((data) {
|
| + return _callback(request, data);
|
| + });
|
| + }
|
| + }
|
| + }
|
| +}
|
|
|
| +http.StreamedResponse stringResponse(
|
| + core.int status, core.Map headers, core.String body) {
|
| + var stream = new async.Stream.fromIterable([convert.UTF8.encode(body)]);
|
| + return new http.StreamedResponse(stream, status, headers: headers);
|
| +}
|
|
|
| core.int buildCounterApproximateProgress = 0;
|
| buildApproximateProgress() {
|
| @@ -60,40 +95,40 @@ checkAutoscalingSettings(api.AutoscalingSettings o) {
|
| buildCounterAutoscalingSettings--;
|
| }
|
|
|
| -buildUnnamed1776() {
|
| +buildUnnamed1492() {
|
| var o = new core.List<api.StreamLocation>();
|
| o.add(buildStreamLocation());
|
| o.add(buildStreamLocation());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1776(core.List<api.StreamLocation> o) {
|
| +checkUnnamed1492(core.List<api.StreamLocation> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkStreamLocation(o[0]);
|
| checkStreamLocation(o[1]);
|
| }
|
|
|
| -buildUnnamed1777() {
|
| +buildUnnamed1493() {
|
| var o = new core.List<api.KeyRangeLocation>();
|
| o.add(buildKeyRangeLocation());
|
| o.add(buildKeyRangeLocation());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1777(core.List<api.KeyRangeLocation> o) {
|
| +checkUnnamed1493(core.List<api.KeyRangeLocation> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkKeyRangeLocation(o[0]);
|
| checkKeyRangeLocation(o[1]);
|
| }
|
|
|
| -buildUnnamed1778() {
|
| +buildUnnamed1494() {
|
| var o = new core.List<api.StreamLocation>();
|
| o.add(buildStreamLocation());
|
| o.add(buildStreamLocation());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1778(core.List<api.StreamLocation> o) {
|
| +checkUnnamed1494(core.List<api.StreamLocation> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkStreamLocation(o[0]);
|
| checkStreamLocation(o[1]);
|
| @@ -105,9 +140,9 @@ buildComputationTopology() {
|
| buildCounterComputationTopology++;
|
| if (buildCounterComputationTopology < 3) {
|
| o.computationId = "foo";
|
| - o.inputs = buildUnnamed1776();
|
| - o.keyRanges = buildUnnamed1777();
|
| - o.outputs = buildUnnamed1778();
|
| + o.inputs = buildUnnamed1492();
|
| + o.keyRanges = buildUnnamed1493();
|
| + o.outputs = buildUnnamed1494();
|
| }
|
| buildCounterComputationTopology--;
|
| return o;
|
| @@ -117,21 +152,21 @@ checkComputationTopology(api.ComputationTopology o) {
|
| buildCounterComputationTopology++;
|
| if (buildCounterComputationTopology < 3) {
|
| unittest.expect(o.computationId, unittest.equals('foo'));
|
| - checkUnnamed1776(o.inputs);
|
| - checkUnnamed1777(o.keyRanges);
|
| - checkUnnamed1778(o.outputs);
|
| + checkUnnamed1492(o.inputs);
|
| + checkUnnamed1493(o.keyRanges);
|
| + checkUnnamed1494(o.outputs);
|
| }
|
| buildCounterComputationTopology--;
|
| }
|
|
|
| -buildUnnamed1779() {
|
| +buildUnnamed1495() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1779(core.List<core.String> o) {
|
| +checkUnnamed1495(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'));
|
| @@ -142,7 +177,7 @@ buildDataDiskAssignment() {
|
| var o = new api.DataDiskAssignment();
|
| buildCounterDataDiskAssignment++;
|
| if (buildCounterDataDiskAssignment < 3) {
|
| - o.dataDisks = buildUnnamed1779();
|
| + o.dataDisks = buildUnnamed1495();
|
| o.vmInstance = "foo";
|
| }
|
| buildCounterDataDiskAssignment--;
|
| @@ -152,12 +187,33 @@ buildDataDiskAssignment() {
|
| checkDataDiskAssignment(api.DataDiskAssignment o) {
|
| buildCounterDataDiskAssignment++;
|
| if (buildCounterDataDiskAssignment < 3) {
|
| - checkUnnamed1779(o.dataDisks);
|
| + checkUnnamed1495(o.dataDisks);
|
| unittest.expect(o.vmInstance, unittest.equals('foo'));
|
| }
|
| buildCounterDataDiskAssignment--;
|
| }
|
|
|
| +core.int buildCounterDerivedSource = 0;
|
| +buildDerivedSource() {
|
| + var o = new api.DerivedSource();
|
| + buildCounterDerivedSource++;
|
| + if (buildCounterDerivedSource < 3) {
|
| + o.derivationMode = "foo";
|
| + o.source = buildSource();
|
| + }
|
| + buildCounterDerivedSource--;
|
| + return o;
|
| +}
|
| +
|
| +checkDerivedSource(api.DerivedSource o) {
|
| + buildCounterDerivedSource++;
|
| + if (buildCounterDerivedSource < 3) {
|
| + unittest.expect(o.derivationMode, unittest.equals('foo'));
|
| + checkSource(o.source);
|
| + }
|
| + buildCounterDerivedSource--;
|
| +}
|
| +
|
| core.int buildCounterDisk = 0;
|
| buildDisk() {
|
| var o = new api.Disk();
|
| @@ -181,66 +237,87 @@ checkDisk(api.Disk o) {
|
| buildCounterDisk--;
|
| }
|
|
|
| -buildUnnamed1780() {
|
| +core.int buildCounterDynamicSourceSplit = 0;
|
| +buildDynamicSourceSplit() {
|
| + var o = new api.DynamicSourceSplit();
|
| + buildCounterDynamicSourceSplit++;
|
| + if (buildCounterDynamicSourceSplit < 3) {
|
| + o.primary = buildDerivedSource();
|
| + o.residual = buildDerivedSource();
|
| + }
|
| + buildCounterDynamicSourceSplit--;
|
| + return o;
|
| +}
|
| +
|
| +checkDynamicSourceSplit(api.DynamicSourceSplit o) {
|
| + buildCounterDynamicSourceSplit++;
|
| + if (buildCounterDynamicSourceSplit < 3) {
|
| + checkDerivedSource(o.primary);
|
| + checkDerivedSource(o.residual);
|
| + }
|
| + buildCounterDynamicSourceSplit--;
|
| +}
|
| +
|
| +buildUnnamed1496() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1780(core.List<core.String> o) {
|
| +checkUnnamed1496(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'));
|
| }
|
|
|
| -buildUnnamed1781() {
|
| +buildUnnamed1497() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1781(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1497(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| var casted1 = (o["x"]) as core.Map; unittest.expect(casted1, unittest.hasLength(3)); unittest.expect(casted1["list"], unittest.equals([1, 2, 3])); unittest.expect(casted1["bool"], unittest.equals(true)); unittest.expect(casted1["string"], unittest.equals('foo'));
|
| var casted2 = (o["y"]) 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'));
|
| }
|
|
|
| -buildUnnamed1782() {
|
| +buildUnnamed1498() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1782(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1498(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| var casted3 = (o["x"]) 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'));
|
| var casted4 = (o["y"]) 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'));
|
| }
|
|
|
| -buildUnnamed1783() {
|
| +buildUnnamed1499() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1783(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1499(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| var casted5 = (o["x"]) 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'));
|
| var casted6 = (o["y"]) 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'));
|
| }
|
|
|
| -buildUnnamed1784() {
|
| +buildUnnamed1500() {
|
| var o = new core.List<api.WorkerPool>();
|
| o.add(buildWorkerPool());
|
| o.add(buildWorkerPool());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1784(core.List<api.WorkerPool> o) {
|
| +checkUnnamed1500(core.List<api.WorkerPool> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkWorkerPool(o[0]);
|
| checkWorkerPool(o[1]);
|
| @@ -253,12 +330,12 @@ buildEnvironment() {
|
| if (buildCounterEnvironment < 3) {
|
| o.clusterManagerApiService = "foo";
|
| o.dataset = "foo";
|
| - o.experiments = buildUnnamed1780();
|
| - o.sdkPipelineOptions = buildUnnamed1781();
|
| + o.experiments = buildUnnamed1496();
|
| + o.sdkPipelineOptions = buildUnnamed1497();
|
| o.tempStoragePrefix = "foo";
|
| - o.userAgent = buildUnnamed1782();
|
| - o.version = buildUnnamed1783();
|
| - o.workerPools = buildUnnamed1784();
|
| + o.userAgent = buildUnnamed1498();
|
| + o.version = buildUnnamed1499();
|
| + o.workerPools = buildUnnamed1500();
|
| }
|
| buildCounterEnvironment--;
|
| return o;
|
| @@ -269,24 +346,24 @@ checkEnvironment(api.Environment o) {
|
| if (buildCounterEnvironment < 3) {
|
| unittest.expect(o.clusterManagerApiService, unittest.equals('foo'));
|
| unittest.expect(o.dataset, unittest.equals('foo'));
|
| - checkUnnamed1780(o.experiments);
|
| - checkUnnamed1781(o.sdkPipelineOptions);
|
| + checkUnnamed1496(o.experiments);
|
| + checkUnnamed1497(o.sdkPipelineOptions);
|
| unittest.expect(o.tempStoragePrefix, unittest.equals('foo'));
|
| - checkUnnamed1782(o.userAgent);
|
| - checkUnnamed1783(o.version);
|
| - checkUnnamed1784(o.workerPools);
|
| + checkUnnamed1498(o.userAgent);
|
| + checkUnnamed1499(o.version);
|
| + checkUnnamed1500(o.workerPools);
|
| }
|
| buildCounterEnvironment--;
|
| }
|
|
|
| -buildUnnamed1785() {
|
| +buildUnnamed1501() {
|
| var o = new core.List<api.InstructionInput>();
|
| o.add(buildInstructionInput());
|
| o.add(buildInstructionInput());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1785(core.List<api.InstructionInput> o) {
|
| +checkUnnamed1501(core.List<api.InstructionInput> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkInstructionInput(o[0]);
|
| checkInstructionInput(o[1]);
|
| @@ -297,7 +374,7 @@ buildFlattenInstruction() {
|
| var o = new api.FlattenInstruction();
|
| buildCounterFlattenInstruction++;
|
| if (buildCounterFlattenInstruction < 3) {
|
| - o.inputs = buildUnnamed1785();
|
| + o.inputs = buildUnnamed1501();
|
| }
|
| buildCounterFlattenInstruction--;
|
| return o;
|
| @@ -306,7 +383,7 @@ buildFlattenInstruction() {
|
| checkFlattenInstruction(api.FlattenInstruction o) {
|
| buildCounterFlattenInstruction++;
|
| if (buildCounterFlattenInstruction < 3) {
|
| - checkUnnamed1785(o.inputs);
|
| + checkUnnamed1501(o.inputs);
|
| }
|
| buildCounterFlattenInstruction--;
|
| }
|
| @@ -332,14 +409,14 @@ checkInstructionInput(api.InstructionInput o) {
|
| buildCounterInstructionInput--;
|
| }
|
|
|
| -buildUnnamed1786() {
|
| +buildUnnamed1502() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1786(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1502(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| var casted7 = (o["x"]) 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'));
|
| var casted8 = (o["y"]) 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'));
|
| @@ -350,7 +427,7 @@ buildInstructionOutput() {
|
| var o = new api.InstructionOutput();
|
| buildCounterInstructionOutput++;
|
| if (buildCounterInstructionOutput < 3) {
|
| - o.codec = buildUnnamed1786();
|
| + o.codec = buildUnnamed1502();
|
| o.name = "foo";
|
| }
|
| buildCounterInstructionOutput--;
|
| @@ -360,20 +437,20 @@ buildInstructionOutput() {
|
| checkInstructionOutput(api.InstructionOutput o) {
|
| buildCounterInstructionOutput++;
|
| if (buildCounterInstructionOutput < 3) {
|
| - checkUnnamed1786(o.codec);
|
| + checkUnnamed1502(o.codec);
|
| unittest.expect(o.name, unittest.equals('foo'));
|
| }
|
| buildCounterInstructionOutput--;
|
| }
|
|
|
| -buildUnnamed1787() {
|
| +buildUnnamed1503() {
|
| var o = new core.List<api.Step>();
|
| o.add(buildStep());
|
| o.add(buildStep());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1787(core.List<api.Step> o) {
|
| +checkUnnamed1503(core.List<api.Step> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkStep(o[0]);
|
| checkStep(o[1]);
|
| @@ -393,7 +470,7 @@ buildJob() {
|
| o.name = "foo";
|
| o.projectId = "foo";
|
| o.requestedState = "foo";
|
| - o.steps = buildUnnamed1787();
|
| + o.steps = buildUnnamed1503();
|
| o.type = "foo";
|
| }
|
| buildCounterJob--;
|
| @@ -412,20 +489,20 @@ checkJob(api.Job o) {
|
| unittest.expect(o.name, unittest.equals('foo'));
|
| unittest.expect(o.projectId, unittest.equals('foo'));
|
| unittest.expect(o.requestedState, unittest.equals('foo'));
|
| - checkUnnamed1787(o.steps);
|
| + checkUnnamed1503(o.steps);
|
| unittest.expect(o.type, unittest.equals('foo'));
|
| }
|
| buildCounterJob--;
|
| }
|
|
|
| -buildUnnamed1788() {
|
| +buildUnnamed1504() {
|
| var o = new core.Map<core.String, api.JobExecutionStageInfo>();
|
| o["x"] = buildJobExecutionStageInfo();
|
| o["y"] = buildJobExecutionStageInfo();
|
| return o;
|
| }
|
|
|
| -checkUnnamed1788(core.Map<core.String, api.JobExecutionStageInfo> o) {
|
| +checkUnnamed1504(core.Map<core.String, api.JobExecutionStageInfo> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkJobExecutionStageInfo(o["x"]);
|
| checkJobExecutionStageInfo(o["y"]);
|
| @@ -436,7 +513,7 @@ buildJobExecutionInfo() {
|
| var o = new api.JobExecutionInfo();
|
| buildCounterJobExecutionInfo++;
|
| if (buildCounterJobExecutionInfo < 3) {
|
| - o.stages = buildUnnamed1788();
|
| + o.stages = buildUnnamed1504();
|
| }
|
| buildCounterJobExecutionInfo--;
|
| return o;
|
| @@ -445,19 +522,19 @@ buildJobExecutionInfo() {
|
| checkJobExecutionInfo(api.JobExecutionInfo o) {
|
| buildCounterJobExecutionInfo++;
|
| if (buildCounterJobExecutionInfo < 3) {
|
| - checkUnnamed1788(o.stages);
|
| + checkUnnamed1504(o.stages);
|
| }
|
| buildCounterJobExecutionInfo--;
|
| }
|
|
|
| -buildUnnamed1789() {
|
| +buildUnnamed1505() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1789(core.List<core.String> o) {
|
| +checkUnnamed1505(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'));
|
| @@ -468,7 +545,7 @@ buildJobExecutionStageInfo() {
|
| var o = new api.JobExecutionStageInfo();
|
| buildCounterJobExecutionStageInfo++;
|
| if (buildCounterJobExecutionStageInfo < 3) {
|
| - o.stepName = buildUnnamed1789();
|
| + o.stepName = buildUnnamed1505();
|
| }
|
| buildCounterJobExecutionStageInfo--;
|
| return o;
|
| @@ -477,7 +554,7 @@ buildJobExecutionStageInfo() {
|
| checkJobExecutionStageInfo(api.JobExecutionStageInfo o) {
|
| buildCounterJobExecutionStageInfo++;
|
| if (buildCounterJobExecutionStageInfo < 3) {
|
| - checkUnnamed1789(o.stepName);
|
| + checkUnnamed1505(o.stepName);
|
| }
|
| buildCounterJobExecutionStageInfo--;
|
| }
|
| @@ -507,14 +584,14 @@ checkJobMessage(api.JobMessage o) {
|
| buildCounterJobMessage--;
|
| }
|
|
|
| -buildUnnamed1790() {
|
| +buildUnnamed1506() {
|
| var o = new core.List<api.MetricUpdate>();
|
| o.add(buildMetricUpdate());
|
| o.add(buildMetricUpdate());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1790(core.List<api.MetricUpdate> o) {
|
| +checkUnnamed1506(core.List<api.MetricUpdate> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkMetricUpdate(o[0]);
|
| checkMetricUpdate(o[1]);
|
| @@ -526,7 +603,7 @@ buildJobMetrics() {
|
| buildCounterJobMetrics++;
|
| if (buildCounterJobMetrics < 3) {
|
| o.metricTime = "foo";
|
| - o.metrics = buildUnnamed1790();
|
| + o.metrics = buildUnnamed1506();
|
| }
|
| buildCounterJobMetrics--;
|
| return o;
|
| @@ -536,11 +613,34 @@ checkJobMetrics(api.JobMetrics o) {
|
| buildCounterJobMetrics++;
|
| if (buildCounterJobMetrics < 3) {
|
| unittest.expect(o.metricTime, unittest.equals('foo'));
|
| - checkUnnamed1790(o.metrics);
|
| + checkUnnamed1506(o.metrics);
|
| }
|
| buildCounterJobMetrics--;
|
| }
|
|
|
| +core.int buildCounterKeyRangeDataDiskAssignment = 0;
|
| +buildKeyRangeDataDiskAssignment() {
|
| + var o = new api.KeyRangeDataDiskAssignment();
|
| + buildCounterKeyRangeDataDiskAssignment++;
|
| + if (buildCounterKeyRangeDataDiskAssignment < 3) {
|
| + o.dataDisk = "foo";
|
| + o.end = "foo";
|
| + o.start = "foo";
|
| + }
|
| + buildCounterKeyRangeDataDiskAssignment--;
|
| + return o;
|
| +}
|
| +
|
| +checkKeyRangeDataDiskAssignment(api.KeyRangeDataDiskAssignment o) {
|
| + buildCounterKeyRangeDataDiskAssignment++;
|
| + if (buildCounterKeyRangeDataDiskAssignment < 3) {
|
| + unittest.expect(o.dataDisk, unittest.equals('foo'));
|
| + unittest.expect(o.end, unittest.equals('foo'));
|
| + unittest.expect(o.start, unittest.equals('foo'));
|
| + }
|
| + buildCounterKeyRangeDataDiskAssignment--;
|
| +}
|
| +
|
| core.int buildCounterKeyRangeLocation = 0;
|
| buildKeyRangeLocation() {
|
| var o = new api.KeyRangeLocation();
|
| @@ -568,27 +668,27 @@ checkKeyRangeLocation(api.KeyRangeLocation o) {
|
| buildCounterKeyRangeLocation--;
|
| }
|
|
|
| -buildUnnamed1791() {
|
| +buildUnnamed1507() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1791(core.List<core.String> o) {
|
| +checkUnnamed1507(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'));
|
| }
|
|
|
| -buildUnnamed1792() {
|
| +buildUnnamed1508() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1792(core.List<core.String> o) {
|
| +checkUnnamed1508(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'));
|
| @@ -601,8 +701,8 @@ buildLeaseWorkItemRequest() {
|
| if (buildCounterLeaseWorkItemRequest < 3) {
|
| o.currentWorkerTime = "foo";
|
| o.requestedLeaseDuration = "foo";
|
| - o.workItemTypes = buildUnnamed1791();
|
| - o.workerCapabilities = buildUnnamed1792();
|
| + o.workItemTypes = buildUnnamed1507();
|
| + o.workerCapabilities = buildUnnamed1508();
|
| o.workerId = "foo";
|
| }
|
| buildCounterLeaseWorkItemRequest--;
|
| @@ -614,21 +714,21 @@ checkLeaseWorkItemRequest(api.LeaseWorkItemRequest o) {
|
| if (buildCounterLeaseWorkItemRequest < 3) {
|
| unittest.expect(o.currentWorkerTime, unittest.equals('foo'));
|
| unittest.expect(o.requestedLeaseDuration, unittest.equals('foo'));
|
| - checkUnnamed1791(o.workItemTypes);
|
| - checkUnnamed1792(o.workerCapabilities);
|
| + checkUnnamed1507(o.workItemTypes);
|
| + checkUnnamed1508(o.workerCapabilities);
|
| unittest.expect(o.workerId, unittest.equals('foo'));
|
| }
|
| buildCounterLeaseWorkItemRequest--;
|
| }
|
|
|
| -buildUnnamed1793() {
|
| +buildUnnamed1509() {
|
| var o = new core.List<api.WorkItem>();
|
| o.add(buildWorkItem());
|
| o.add(buildWorkItem());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1793(core.List<api.WorkItem> o) {
|
| +checkUnnamed1509(core.List<api.WorkItem> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkWorkItem(o[0]);
|
| checkWorkItem(o[1]);
|
| @@ -639,7 +739,7 @@ buildLeaseWorkItemResponse() {
|
| var o = new api.LeaseWorkItemResponse();
|
| buildCounterLeaseWorkItemResponse++;
|
| if (buildCounterLeaseWorkItemResponse < 3) {
|
| - o.workItems = buildUnnamed1793();
|
| + o.workItems = buildUnnamed1509();
|
| }
|
| buildCounterLeaseWorkItemResponse--;
|
| return o;
|
| @@ -648,19 +748,19 @@ buildLeaseWorkItemResponse() {
|
| checkLeaseWorkItemResponse(api.LeaseWorkItemResponse o) {
|
| buildCounterLeaseWorkItemResponse++;
|
| if (buildCounterLeaseWorkItemResponse < 3) {
|
| - checkUnnamed1793(o.workItems);
|
| + checkUnnamed1509(o.workItems);
|
| }
|
| buildCounterLeaseWorkItemResponse--;
|
| }
|
|
|
| -buildUnnamed1794() {
|
| +buildUnnamed1510() {
|
| var o = new core.List<api.JobMessage>();
|
| o.add(buildJobMessage());
|
| o.add(buildJobMessage());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1794(core.List<api.JobMessage> o) {
|
| +checkUnnamed1510(core.List<api.JobMessage> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkJobMessage(o[0]);
|
| checkJobMessage(o[1]);
|
| @@ -671,7 +771,7 @@ buildListJobMessagesResponse() {
|
| var o = new api.ListJobMessagesResponse();
|
| buildCounterListJobMessagesResponse++;
|
| if (buildCounterListJobMessagesResponse < 3) {
|
| - o.jobMessages = buildUnnamed1794();
|
| + o.jobMessages = buildUnnamed1510();
|
| o.nextPageToken = "foo";
|
| }
|
| buildCounterListJobMessagesResponse--;
|
| @@ -681,20 +781,20 @@ buildListJobMessagesResponse() {
|
| checkListJobMessagesResponse(api.ListJobMessagesResponse o) {
|
| buildCounterListJobMessagesResponse++;
|
| if (buildCounterListJobMessagesResponse < 3) {
|
| - checkUnnamed1794(o.jobMessages);
|
| + checkUnnamed1510(o.jobMessages);
|
| unittest.expect(o.nextPageToken, unittest.equals('foo'));
|
| }
|
| buildCounterListJobMessagesResponse--;
|
| }
|
|
|
| -buildUnnamed1795() {
|
| +buildUnnamed1511() {
|
| var o = new core.List<api.Job>();
|
| o.add(buildJob());
|
| o.add(buildJob());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1795(core.List<api.Job> o) {
|
| +checkUnnamed1511(core.List<api.Job> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkJob(o[0]);
|
| checkJob(o[1]);
|
| @@ -705,7 +805,7 @@ buildListJobsResponse() {
|
| var o = new api.ListJobsResponse();
|
| buildCounterListJobsResponse++;
|
| if (buildCounterListJobsResponse < 3) {
|
| - o.jobs = buildUnnamed1795();
|
| + o.jobs = buildUnnamed1511();
|
| o.nextPageToken = "foo";
|
| }
|
| buildCounterListJobsResponse--;
|
| @@ -715,20 +815,20 @@ buildListJobsResponse() {
|
| checkListJobsResponse(api.ListJobsResponse o) {
|
| buildCounterListJobsResponse++;
|
| if (buildCounterListJobsResponse < 3) {
|
| - checkUnnamed1795(o.jobs);
|
| + checkUnnamed1511(o.jobs);
|
| unittest.expect(o.nextPageToken, unittest.equals('foo'));
|
| }
|
| buildCounterListJobsResponse--;
|
| }
|
|
|
| -buildUnnamed1796() {
|
| +buildUnnamed1512() {
|
| var o = new core.List<api.ParallelInstruction>();
|
| o.add(buildParallelInstruction());
|
| o.add(buildParallelInstruction());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1796(core.List<api.ParallelInstruction> o) {
|
| +checkUnnamed1512(core.List<api.ParallelInstruction> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkParallelInstruction(o[0]);
|
| checkParallelInstruction(o[1]);
|
| @@ -739,7 +839,7 @@ buildMapTask() {
|
| var o = new api.MapTask();
|
| buildCounterMapTask++;
|
| if (buildCounterMapTask < 3) {
|
| - o.instructions = buildUnnamed1796();
|
| + o.instructions = buildUnnamed1512();
|
| o.stageName = "foo";
|
| o.systemName = "foo";
|
| }
|
| @@ -750,21 +850,21 @@ buildMapTask() {
|
| checkMapTask(api.MapTask o) {
|
| buildCounterMapTask++;
|
| if (buildCounterMapTask < 3) {
|
| - checkUnnamed1796(o.instructions);
|
| + checkUnnamed1512(o.instructions);
|
| unittest.expect(o.stageName, unittest.equals('foo'));
|
| unittest.expect(o.systemName, unittest.equals('foo'));
|
| }
|
| buildCounterMapTask--;
|
| }
|
|
|
| -buildUnnamed1797() {
|
| +buildUnnamed1513() {
|
| var o = new core.Map<core.String, core.String>();
|
| o["x"] = "foo";
|
| o["y"] = "foo";
|
| return o;
|
| }
|
|
|
| -checkUnnamed1797(core.Map<core.String, core.String> o) {
|
| +checkUnnamed1513(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'));
|
| @@ -775,7 +875,7 @@ buildMetricStructuredName() {
|
| var o = new api.MetricStructuredName();
|
| buildCounterMetricStructuredName++;
|
| if (buildCounterMetricStructuredName < 3) {
|
| - o.context = buildUnnamed1797();
|
| + o.context = buildUnnamed1513();
|
| o.name = "foo";
|
| o.origin = "foo";
|
| }
|
| @@ -786,7 +886,7 @@ buildMetricStructuredName() {
|
| checkMetricStructuredName(api.MetricStructuredName o) {
|
| buildCounterMetricStructuredName++;
|
| if (buildCounterMetricStructuredName < 3) {
|
| - checkUnnamed1797(o.context);
|
| + checkUnnamed1513(o.context);
|
| unittest.expect(o.name, unittest.equals('foo'));
|
| unittest.expect(o.origin, unittest.equals('foo'));
|
| }
|
| @@ -828,6 +928,25 @@ checkMetricUpdate(api.MetricUpdate o) {
|
| buildCounterMetricUpdate--;
|
| }
|
|
|
| +core.int buildCounterMountedDataDisk = 0;
|
| +buildMountedDataDisk() {
|
| + var o = new api.MountedDataDisk();
|
| + buildCounterMountedDataDisk++;
|
| + if (buildCounterMountedDataDisk < 3) {
|
| + o.dataDisk = "foo";
|
| + }
|
| + buildCounterMountedDataDisk--;
|
| + return o;
|
| +}
|
| +
|
| +checkMountedDataDisk(api.MountedDataDisk o) {
|
| + buildCounterMountedDataDisk++;
|
| + if (buildCounterMountedDataDisk < 3) {
|
| + unittest.expect(o.dataDisk, unittest.equals('foo'));
|
| + }
|
| + buildCounterMountedDataDisk--;
|
| +}
|
| +
|
| core.int buildCounterMultiOutputInfo = 0;
|
| buildMultiOutputInfo() {
|
| var o = new api.MultiOutputInfo();
|
| @@ -868,40 +987,40 @@ checkPackage(api.Package o) {
|
| buildCounterPackage--;
|
| }
|
|
|
| -buildUnnamed1798() {
|
| +buildUnnamed1514() {
|
| var o = new core.List<api.MultiOutputInfo>();
|
| o.add(buildMultiOutputInfo());
|
| o.add(buildMultiOutputInfo());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1798(core.List<api.MultiOutputInfo> o) {
|
| +checkUnnamed1514(core.List<api.MultiOutputInfo> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkMultiOutputInfo(o[0]);
|
| checkMultiOutputInfo(o[1]);
|
| }
|
|
|
| -buildUnnamed1799() {
|
| +buildUnnamed1515() {
|
| var o = new core.List<api.SideInputInfo>();
|
| o.add(buildSideInputInfo());
|
| o.add(buildSideInputInfo());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1799(core.List<api.SideInputInfo> o) {
|
| +checkUnnamed1515(core.List<api.SideInputInfo> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkSideInputInfo(o[0]);
|
| checkSideInputInfo(o[1]);
|
| }
|
|
|
| -buildUnnamed1800() {
|
| +buildUnnamed1516() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1800(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1516(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| var casted14 = (o["x"]) as core.Map; unittest.expect(casted14, unittest.hasLength(3)); unittest.expect(casted14["list"], unittest.equals([1, 2, 3])); unittest.expect(casted14["bool"], unittest.equals(true)); unittest.expect(casted14["string"], unittest.equals('foo'));
|
| var casted15 = (o["y"]) as core.Map; unittest.expect(casted15, unittest.hasLength(3)); unittest.expect(casted15["list"], unittest.equals([1, 2, 3])); unittest.expect(casted15["bool"], unittest.equals(true)); unittest.expect(casted15["string"], unittest.equals('foo'));
|
| @@ -913,10 +1032,10 @@ buildParDoInstruction() {
|
| buildCounterParDoInstruction++;
|
| if (buildCounterParDoInstruction < 3) {
|
| o.input = buildInstructionInput();
|
| - o.multiOutputInfos = buildUnnamed1798();
|
| + o.multiOutputInfos = buildUnnamed1514();
|
| o.numOutputs = 42;
|
| - o.sideInputs = buildUnnamed1799();
|
| - o.userFn = buildUnnamed1800();
|
| + o.sideInputs = buildUnnamed1515();
|
| + o.userFn = buildUnnamed1516();
|
| }
|
| buildCounterParDoInstruction--;
|
| return o;
|
| @@ -926,22 +1045,22 @@ checkParDoInstruction(api.ParDoInstruction o) {
|
| buildCounterParDoInstruction++;
|
| if (buildCounterParDoInstruction < 3) {
|
| checkInstructionInput(o.input);
|
| - checkUnnamed1798(o.multiOutputInfos);
|
| + checkUnnamed1514(o.multiOutputInfos);
|
| unittest.expect(o.numOutputs, unittest.equals(42));
|
| - checkUnnamed1799(o.sideInputs);
|
| - checkUnnamed1800(o.userFn);
|
| + checkUnnamed1515(o.sideInputs);
|
| + checkUnnamed1516(o.userFn);
|
| }
|
| buildCounterParDoInstruction--;
|
| }
|
|
|
| -buildUnnamed1801() {
|
| +buildUnnamed1517() {
|
| var o = new core.List<api.InstructionOutput>();
|
| o.add(buildInstructionOutput());
|
| o.add(buildInstructionOutput());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1801(core.List<api.InstructionOutput> o) {
|
| +checkUnnamed1517(core.List<api.InstructionOutput> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkInstructionOutput(o[0]);
|
| checkInstructionOutput(o[1]);
|
| @@ -954,7 +1073,7 @@ buildParallelInstruction() {
|
| if (buildCounterParallelInstruction < 3) {
|
| o.flatten = buildFlattenInstruction();
|
| o.name = "foo";
|
| - o.outputs = buildUnnamed1801();
|
| + o.outputs = buildUnnamed1517();
|
| o.parDo = buildParDoInstruction();
|
| o.partialGroupByKey = buildPartialGroupByKeyInstruction();
|
| o.read = buildReadInstruction();
|
| @@ -970,7 +1089,7 @@ checkParallelInstruction(api.ParallelInstruction o) {
|
| if (buildCounterParallelInstruction < 3) {
|
| checkFlattenInstruction(o.flatten);
|
| unittest.expect(o.name, unittest.equals('foo'));
|
| - checkUnnamed1801(o.outputs);
|
| + checkUnnamed1517(o.outputs);
|
| checkParDoInstruction(o.parDo);
|
| checkPartialGroupByKeyInstruction(o.partialGroupByKey);
|
| checkReadInstruction(o.read);
|
| @@ -980,26 +1099,40 @@ checkParallelInstruction(api.ParallelInstruction o) {
|
| buildCounterParallelInstruction--;
|
| }
|
|
|
| -buildUnnamed1802() {
|
| +buildUnnamed1518() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1802(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1518(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| var casted16 = (o["x"]) as core.Map; unittest.expect(casted16, unittest.hasLength(3)); unittest.expect(casted16["list"], unittest.equals([1, 2, 3])); unittest.expect(casted16["bool"], unittest.equals(true)); unittest.expect(casted16["string"], unittest.equals('foo'));
|
| var casted17 = (o["y"]) as core.Map; unittest.expect(casted17, unittest.hasLength(3)); unittest.expect(casted17["list"], unittest.equals([1, 2, 3])); unittest.expect(casted17["bool"], unittest.equals(true)); unittest.expect(casted17["string"], unittest.equals('foo'));
|
| }
|
|
|
| +buildUnnamed1519() {
|
| + 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;
|
| +}
|
| +
|
| +checkUnnamed1519(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'));
|
| +}
|
| +
|
| core.int buildCounterPartialGroupByKeyInstruction = 0;
|
| buildPartialGroupByKeyInstruction() {
|
| var o = new api.PartialGroupByKeyInstruction();
|
| buildCounterPartialGroupByKeyInstruction++;
|
| if (buildCounterPartialGroupByKeyInstruction < 3) {
|
| o.input = buildInstructionInput();
|
| - o.inputElementCodec = buildUnnamed1802();
|
| + o.inputElementCodec = buildUnnamed1518();
|
| + o.valueCombiningFn = buildUnnamed1519();
|
| }
|
| buildCounterPartialGroupByKeyInstruction--;
|
| return o;
|
| @@ -1009,7 +1142,8 @@ checkPartialGroupByKeyInstruction(api.PartialGroupByKeyInstruction o) {
|
| buildCounterPartialGroupByKeyInstruction++;
|
| if (buildCounterPartialGroupByKeyInstruction < 3) {
|
| checkInstructionInput(o.input);
|
| - checkUnnamed1802(o.inputElementCodec);
|
| + checkUnnamed1518(o.inputElementCodec);
|
| + checkUnnamed1519(o.valueCombiningFn);
|
| }
|
| buildCounterPartialGroupByKeyInstruction--;
|
| }
|
| @@ -1051,6 +1185,7 @@ buildPubsubLocation() {
|
| o.subscription = "foo";
|
| o.timestampLabel = "foo";
|
| o.topic = "foo";
|
| + o.trackingSubscription = "foo";
|
| }
|
| buildCounterPubsubLocation--;
|
| return o;
|
| @@ -1064,6 +1199,7 @@ checkPubsubLocation(api.PubsubLocation o) {
|
| unittest.expect(o.subscription, unittest.equals('foo'));
|
| unittest.expect(o.timestampLabel, unittest.equals('foo'));
|
| unittest.expect(o.topic, unittest.equals('foo'));
|
| + unittest.expect(o.trackingSubscription, unittest.equals('foo'));
|
| }
|
| buildCounterPubsubLocation--;
|
| }
|
| @@ -1087,14 +1223,14 @@ checkReadInstruction(api.ReadInstruction o) {
|
| buildCounterReadInstruction--;
|
| }
|
|
|
| -buildUnnamed1803() {
|
| +buildUnnamed1520() {
|
| var o = new core.List<api.WorkItemStatus>();
|
| o.add(buildWorkItemStatus());
|
| o.add(buildWorkItemStatus());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1803(core.List<api.WorkItemStatus> o) {
|
| +checkUnnamed1520(core.List<api.WorkItemStatus> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkWorkItemStatus(o[0]);
|
| checkWorkItemStatus(o[1]);
|
| @@ -1106,7 +1242,7 @@ buildReportWorkItemStatusRequest() {
|
| buildCounterReportWorkItemStatusRequest++;
|
| if (buildCounterReportWorkItemStatusRequest < 3) {
|
| o.currentWorkerTime = "foo";
|
| - o.workItemStatuses = buildUnnamed1803();
|
| + o.workItemStatuses = buildUnnamed1520();
|
| o.workerId = "foo";
|
| }
|
| buildCounterReportWorkItemStatusRequest--;
|
| @@ -1117,20 +1253,20 @@ checkReportWorkItemStatusRequest(api.ReportWorkItemStatusRequest o) {
|
| buildCounterReportWorkItemStatusRequest++;
|
| if (buildCounterReportWorkItemStatusRequest < 3) {
|
| unittest.expect(o.currentWorkerTime, unittest.equals('foo'));
|
| - checkUnnamed1803(o.workItemStatuses);
|
| + checkUnnamed1520(o.workItemStatuses);
|
| unittest.expect(o.workerId, unittest.equals('foo'));
|
| }
|
| buildCounterReportWorkItemStatusRequest--;
|
| }
|
|
|
| -buildUnnamed1804() {
|
| +buildUnnamed1521() {
|
| var o = new core.List<api.WorkItemServiceState>();
|
| o.add(buildWorkItemServiceState());
|
| o.add(buildWorkItemServiceState());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1804(core.List<api.WorkItemServiceState> o) {
|
| +checkUnnamed1521(core.List<api.WorkItemServiceState> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkWorkItemServiceState(o[0]);
|
| checkWorkItemServiceState(o[1]);
|
| @@ -1141,7 +1277,7 @@ buildReportWorkItemStatusResponse() {
|
| var o = new api.ReportWorkItemStatusResponse();
|
| buildCounterReportWorkItemStatusResponse++;
|
| if (buildCounterReportWorkItemStatusResponse < 3) {
|
| - o.workItemServiceStates = buildUnnamed1804();
|
| + o.workItemServiceStates = buildUnnamed1521();
|
| }
|
| buildCounterReportWorkItemStatusResponse--;
|
| return o;
|
| @@ -1150,48 +1286,48 @@ buildReportWorkItemStatusResponse() {
|
| checkReportWorkItemStatusResponse(api.ReportWorkItemStatusResponse o) {
|
| buildCounterReportWorkItemStatusResponse++;
|
| if (buildCounterReportWorkItemStatusResponse < 3) {
|
| - checkUnnamed1804(o.workItemServiceStates);
|
| + checkUnnamed1521(o.workItemServiceStates);
|
| }
|
| buildCounterReportWorkItemStatusResponse--;
|
| }
|
|
|
| -buildUnnamed1805() {
|
| +buildUnnamed1522() {
|
| var o = new core.List<api.SideInputInfo>();
|
| o.add(buildSideInputInfo());
|
| o.add(buildSideInputInfo());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1805(core.List<api.SideInputInfo> o) {
|
| +checkUnnamed1522(core.List<api.SideInputInfo> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkSideInputInfo(o[0]);
|
| checkSideInputInfo(o[1]);
|
| }
|
|
|
| -buildUnnamed1806() {
|
| +buildUnnamed1523() {
|
| var o = new core.List<api.SeqMapTaskOutputInfo>();
|
| o.add(buildSeqMapTaskOutputInfo());
|
| o.add(buildSeqMapTaskOutputInfo());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1806(core.List<api.SeqMapTaskOutputInfo> o) {
|
| +checkUnnamed1523(core.List<api.SeqMapTaskOutputInfo> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkSeqMapTaskOutputInfo(o[0]);
|
| checkSeqMapTaskOutputInfo(o[1]);
|
| }
|
|
|
| -buildUnnamed1807() {
|
| +buildUnnamed1524() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1807(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1524(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'));
|
| + var casted20 = (o["x"]) as core.Map; unittest.expect(casted20, unittest.hasLength(3)); unittest.expect(casted20["list"], unittest.equals([1, 2, 3])); unittest.expect(casted20["bool"], unittest.equals(true)); unittest.expect(casted20["string"], unittest.equals('foo'));
|
| + var casted21 = (o["y"]) as core.Map; unittest.expect(casted21, unittest.hasLength(3)); unittest.expect(casted21["list"], unittest.equals([1, 2, 3])); unittest.expect(casted21["bool"], unittest.equals(true)); unittest.expect(casted21["string"], unittest.equals('foo'));
|
| }
|
|
|
| core.int buildCounterSeqMapTask = 0;
|
| @@ -1199,12 +1335,12 @@ buildSeqMapTask() {
|
| var o = new api.SeqMapTask();
|
| buildCounterSeqMapTask++;
|
| if (buildCounterSeqMapTask < 3) {
|
| - o.inputs = buildUnnamed1805();
|
| + o.inputs = buildUnnamed1522();
|
| o.name = "foo";
|
| - o.outputInfos = buildUnnamed1806();
|
| + o.outputInfos = buildUnnamed1523();
|
| o.stageName = "foo";
|
| o.systemName = "foo";
|
| - o.userFn = buildUnnamed1807();
|
| + o.userFn = buildUnnamed1524();
|
| }
|
| buildCounterSeqMapTask--;
|
| return o;
|
| @@ -1213,12 +1349,12 @@ buildSeqMapTask() {
|
| checkSeqMapTask(api.SeqMapTask o) {
|
| buildCounterSeqMapTask++;
|
| if (buildCounterSeqMapTask < 3) {
|
| - checkUnnamed1805(o.inputs);
|
| + checkUnnamed1522(o.inputs);
|
| unittest.expect(o.name, unittest.equals('foo'));
|
| - checkUnnamed1806(o.outputInfos);
|
| + checkUnnamed1523(o.outputInfos);
|
| unittest.expect(o.stageName, unittest.equals('foo'));
|
| unittest.expect(o.systemName, unittest.equals('foo'));
|
| - checkUnnamed1807(o.userFn);
|
| + checkUnnamed1524(o.userFn);
|
| }
|
| buildCounterSeqMapTask--;
|
| }
|
| @@ -1265,27 +1401,27 @@ checkShellTask(api.ShellTask o) {
|
| buildCounterShellTask--;
|
| }
|
|
|
| -buildUnnamed1808() {
|
| +buildUnnamed1525() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1808(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1525(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| - var casted20 = (o["x"]) as core.Map; unittest.expect(casted20, unittest.hasLength(3)); unittest.expect(casted20["list"], unittest.equals([1, 2, 3])); unittest.expect(casted20["bool"], unittest.equals(true)); unittest.expect(casted20["string"], unittest.equals('foo'));
|
| - var casted21 = (o["y"]) as core.Map; unittest.expect(casted21, unittest.hasLength(3)); unittest.expect(casted21["list"], unittest.equals([1, 2, 3])); unittest.expect(casted21["bool"], unittest.equals(true)); unittest.expect(casted21["string"], unittest.equals('foo'));
|
| + var casted22 = (o["x"]) as core.Map; unittest.expect(casted22, unittest.hasLength(3)); unittest.expect(casted22["list"], unittest.equals([1, 2, 3])); unittest.expect(casted22["bool"], unittest.equals(true)); unittest.expect(casted22["string"], unittest.equals('foo'));
|
| + var casted23 = (o["y"]) as core.Map; unittest.expect(casted23, unittest.hasLength(3)); unittest.expect(casted23["list"], unittest.equals([1, 2, 3])); unittest.expect(casted23["bool"], unittest.equals(true)); unittest.expect(casted23["string"], unittest.equals('foo'));
|
| }
|
|
|
| -buildUnnamed1809() {
|
| +buildUnnamed1526() {
|
| var o = new core.List<api.Source>();
|
| o.add(buildSource());
|
| o.add(buildSource());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1809(core.List<api.Source> o) {
|
| +checkUnnamed1526(core.List<api.Source> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkSource(o[0]);
|
| checkSource(o[1]);
|
| @@ -1296,8 +1432,8 @@ buildSideInputInfo() {
|
| var o = new api.SideInputInfo();
|
| buildCounterSideInputInfo++;
|
| if (buildCounterSideInputInfo < 3) {
|
| - o.kind = buildUnnamed1808();
|
| - o.sources = buildUnnamed1809();
|
| + o.kind = buildUnnamed1525();
|
| + o.sources = buildUnnamed1526();
|
| o.tag = "foo";
|
| }
|
| buildCounterSideInputInfo--;
|
| @@ -1307,37 +1443,37 @@ buildSideInputInfo() {
|
| checkSideInputInfo(api.SideInputInfo o) {
|
| buildCounterSideInputInfo++;
|
| if (buildCounterSideInputInfo < 3) {
|
| - checkUnnamed1808(o.kind);
|
| - checkUnnamed1809(o.sources);
|
| + checkUnnamed1525(o.kind);
|
| + checkUnnamed1526(o.sources);
|
| unittest.expect(o.tag, unittest.equals('foo'));
|
| }
|
| buildCounterSideInputInfo--;
|
| }
|
|
|
| -buildUnnamed1810() {
|
| +buildUnnamed1527() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1810(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1527(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| - var casted22 = (o["x"]) as core.Map; unittest.expect(casted22, unittest.hasLength(3)); unittest.expect(casted22["list"], unittest.equals([1, 2, 3])); unittest.expect(casted22["bool"], unittest.equals(true)); unittest.expect(casted22["string"], unittest.equals('foo'));
|
| - var casted23 = (o["y"]) as core.Map; unittest.expect(casted23, unittest.hasLength(3)); unittest.expect(casted23["list"], unittest.equals([1, 2, 3])); unittest.expect(casted23["bool"], unittest.equals(true)); unittest.expect(casted23["string"], unittest.equals('foo'));
|
| + var casted24 = (o["x"]) as core.Map; unittest.expect(casted24, unittest.hasLength(3)); unittest.expect(casted24["list"], unittest.equals([1, 2, 3])); unittest.expect(casted24["bool"], unittest.equals(true)); unittest.expect(casted24["string"], unittest.equals('foo'));
|
| + var casted25 = (o["y"]) as core.Map; unittest.expect(casted25, unittest.hasLength(3)); unittest.expect(casted25["list"], unittest.equals([1, 2, 3])); unittest.expect(casted25["bool"], unittest.equals(true)); unittest.expect(casted25["string"], unittest.equals('foo'));
|
| }
|
|
|
| -buildUnnamed1811() {
|
| +buildUnnamed1528() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1811(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1528(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| - var casted24 = (o["x"]) as core.Map; unittest.expect(casted24, unittest.hasLength(3)); unittest.expect(casted24["list"], unittest.equals([1, 2, 3])); unittest.expect(casted24["bool"], unittest.equals(true)); unittest.expect(casted24["string"], unittest.equals('foo'));
|
| - var casted25 = (o["y"]) as core.Map; unittest.expect(casted25, unittest.hasLength(3)); unittest.expect(casted25["list"], unittest.equals([1, 2, 3])); unittest.expect(casted25["bool"], unittest.equals(true)); unittest.expect(casted25["string"], unittest.equals('foo'));
|
| + var casted26 = (o["x"]) as core.Map; unittest.expect(casted26, unittest.hasLength(3)); unittest.expect(casted26["list"], unittest.equals([1, 2, 3])); unittest.expect(casted26["bool"], unittest.equals(true)); unittest.expect(casted26["string"], unittest.equals('foo'));
|
| + var casted27 = (o["y"]) as core.Map; unittest.expect(casted27, unittest.hasLength(3)); unittest.expect(casted27["list"], unittest.equals([1, 2, 3])); unittest.expect(casted27["bool"], unittest.equals(true)); unittest.expect(casted27["string"], unittest.equals('foo'));
|
| }
|
|
|
| core.int buildCounterSink = 0;
|
| @@ -1345,8 +1481,8 @@ buildSink() {
|
| var o = new api.Sink();
|
| buildCounterSink++;
|
| if (buildCounterSink < 3) {
|
| - o.codec = buildUnnamed1810();
|
| - o.spec = buildUnnamed1811();
|
| + o.codec = buildUnnamed1527();
|
| + o.spec = buildUnnamed1528();
|
| }
|
| buildCounterSink--;
|
| return o;
|
| @@ -1355,62 +1491,62 @@ buildSink() {
|
| checkSink(api.Sink o) {
|
| buildCounterSink++;
|
| if (buildCounterSink < 3) {
|
| - checkUnnamed1810(o.codec);
|
| - checkUnnamed1811(o.spec);
|
| + checkUnnamed1527(o.codec);
|
| + checkUnnamed1528(o.spec);
|
| }
|
| buildCounterSink--;
|
| }
|
|
|
| -buildUnnamed1812() {
|
| +buildUnnamed1529() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1812(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1529(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| - var casted26 = (o["x"]) as core.Map; unittest.expect(casted26, unittest.hasLength(3)); unittest.expect(casted26["list"], unittest.equals([1, 2, 3])); unittest.expect(casted26["bool"], unittest.equals(true)); unittest.expect(casted26["string"], unittest.equals('foo'));
|
| - var casted27 = (o["y"]) as core.Map; unittest.expect(casted27, unittest.hasLength(3)); unittest.expect(casted27["list"], unittest.equals([1, 2, 3])); unittest.expect(casted27["bool"], unittest.equals(true)); unittest.expect(casted27["string"], unittest.equals('foo'));
|
| + var casted28 = (o["x"]) as core.Map; unittest.expect(casted28, unittest.hasLength(3)); unittest.expect(casted28["list"], unittest.equals([1, 2, 3])); unittest.expect(casted28["bool"], unittest.equals(true)); unittest.expect(casted28["string"], unittest.equals('foo'));
|
| + var casted29 = (o["y"]) as core.Map; unittest.expect(casted29, unittest.hasLength(3)); unittest.expect(casted29["list"], unittest.equals([1, 2, 3])); unittest.expect(casted29["bool"], unittest.equals(true)); unittest.expect(casted29["string"], unittest.equals('foo'));
|
| }
|
|
|
| -buildUnnamed1813() {
|
| +buildUnnamed1530() {
|
| var o = new core.List<core.Map<core.String, core.Object>>();
|
| - o.add(buildUnnamed1812());
|
| - o.add(buildUnnamed1812());
|
| + o.add(buildUnnamed1529());
|
| + o.add(buildUnnamed1529());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1813(core.List<core.Map<core.String, core.Object>> o) {
|
| +checkUnnamed1530(core.List<core.Map<core.String, core.Object>> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| - checkUnnamed1812(o[0]);
|
| - checkUnnamed1812(o[1]);
|
| + checkUnnamed1529(o[0]);
|
| + checkUnnamed1529(o[1]);
|
| }
|
|
|
| -buildUnnamed1814() {
|
| +buildUnnamed1531() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1814(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1531(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| - var casted28 = (o["x"]) as core.Map; unittest.expect(casted28, unittest.hasLength(3)); unittest.expect(casted28["list"], unittest.equals([1, 2, 3])); unittest.expect(casted28["bool"], unittest.equals(true)); unittest.expect(casted28["string"], unittest.equals('foo'));
|
| - var casted29 = (o["y"]) as core.Map; unittest.expect(casted29, unittest.hasLength(3)); unittest.expect(casted29["list"], unittest.equals([1, 2, 3])); unittest.expect(casted29["bool"], unittest.equals(true)); unittest.expect(casted29["string"], unittest.equals('foo'));
|
| + var casted30 = (o["x"]) as core.Map; unittest.expect(casted30, unittest.hasLength(3)); unittest.expect(casted30["list"], unittest.equals([1, 2, 3])); unittest.expect(casted30["bool"], unittest.equals(true)); unittest.expect(casted30["string"], unittest.equals('foo'));
|
| + var casted31 = (o["y"]) as core.Map; unittest.expect(casted31, unittest.hasLength(3)); unittest.expect(casted31["list"], unittest.equals([1, 2, 3])); unittest.expect(casted31["bool"], unittest.equals(true)); unittest.expect(casted31["string"], unittest.equals('foo'));
|
| }
|
|
|
| -buildUnnamed1815() {
|
| +buildUnnamed1532() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1815(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1532(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| - var casted30 = (o["x"]) as core.Map; unittest.expect(casted30, unittest.hasLength(3)); unittest.expect(casted30["list"], unittest.equals([1, 2, 3])); unittest.expect(casted30["bool"], unittest.equals(true)); unittest.expect(casted30["string"], unittest.equals('foo'));
|
| - var casted31 = (o["y"]) as core.Map; unittest.expect(casted31, unittest.hasLength(3)); unittest.expect(casted31["list"], unittest.equals([1, 2, 3])); unittest.expect(casted31["bool"], unittest.equals(true)); unittest.expect(casted31["string"], unittest.equals('foo'));
|
| + var casted32 = (o["x"]) as core.Map; unittest.expect(casted32, unittest.hasLength(3)); unittest.expect(casted32["list"], unittest.equals([1, 2, 3])); unittest.expect(casted32["bool"], unittest.equals(true)); unittest.expect(casted32["string"], unittest.equals('foo'));
|
| + var casted33 = (o["y"]) as core.Map; unittest.expect(casted33, unittest.hasLength(3)); unittest.expect(casted33["list"], unittest.equals([1, 2, 3])); unittest.expect(casted33["bool"], unittest.equals(true)); unittest.expect(casted33["string"], unittest.equals('foo'));
|
| }
|
|
|
| core.int buildCounterSource = 0;
|
| @@ -1418,11 +1554,11 @@ buildSource() {
|
| var o = new api.Source();
|
| buildCounterSource++;
|
| if (buildCounterSource < 3) {
|
| - o.baseSpecs = buildUnnamed1813();
|
| - o.codec = buildUnnamed1814();
|
| + o.baseSpecs = buildUnnamed1530();
|
| + o.codec = buildUnnamed1531();
|
| o.doesNotNeedSplitting = true;
|
| o.metadata = buildSourceMetadata();
|
| - o.spec = buildUnnamed1815();
|
| + o.spec = buildUnnamed1532();
|
| }
|
| buildCounterSource--;
|
| return o;
|
| @@ -1431,11 +1567,11 @@ buildSource() {
|
| checkSource(api.Source o) {
|
| buildCounterSource++;
|
| if (buildCounterSource < 3) {
|
| - checkUnnamed1813(o.baseSpecs);
|
| - checkUnnamed1814(o.codec);
|
| + checkUnnamed1530(o.baseSpecs);
|
| + checkUnnamed1531(o.codec);
|
| unittest.expect(o.doesNotNeedSplitting, unittest.isTrue);
|
| checkSourceMetadata(o.metadata);
|
| - checkUnnamed1815(o.spec);
|
| + checkUnnamed1532(o.spec);
|
| }
|
| buildCounterSource--;
|
| }
|
| @@ -1446,7 +1582,9 @@ buildSourceFork() {
|
| buildCounterSourceFork++;
|
| if (buildCounterSourceFork < 3) {
|
| o.primary = buildSourceSplitShard();
|
| + o.primarySource = buildDerivedSource();
|
| o.residual = buildSourceSplitShard();
|
| + o.residualSource = buildDerivedSource();
|
| }
|
| buildCounterSourceFork--;
|
| return o;
|
| @@ -1456,7 +1594,9 @@ checkSourceFork(api.SourceFork o) {
|
| buildCounterSourceFork++;
|
| if (buildCounterSourceFork < 3) {
|
| checkSourceSplitShard(o.primary);
|
| + checkDerivedSource(o.primarySource);
|
| checkSourceSplitShard(o.residual);
|
| + checkDerivedSource(o.residualSource);
|
| }
|
| buildCounterSourceFork--;
|
| }
|
| @@ -1569,6 +1709,7 @@ buildSourceSplitOptions() {
|
| var o = new api.SourceSplitOptions();
|
| buildCounterSourceSplitOptions++;
|
| if (buildCounterSourceSplitOptions < 3) {
|
| + o.desiredBundleSizeBytes = "foo";
|
| o.desiredShardSizeBytes = "foo";
|
| }
|
| buildCounterSourceSplitOptions--;
|
| @@ -1578,6 +1719,7 @@ buildSourceSplitOptions() {
|
| checkSourceSplitOptions(api.SourceSplitOptions o) {
|
| buildCounterSourceSplitOptions++;
|
| if (buildCounterSourceSplitOptions < 3) {
|
| + unittest.expect(o.desiredBundleSizeBytes, unittest.equals('foo'));
|
| unittest.expect(o.desiredShardSizeBytes, unittest.equals('foo'));
|
| }
|
| buildCounterSourceSplitOptions--;
|
| @@ -1604,14 +1746,27 @@ checkSourceSplitRequest(api.SourceSplitRequest o) {
|
| buildCounterSourceSplitRequest--;
|
| }
|
|
|
| -buildUnnamed1816() {
|
| +buildUnnamed1533() {
|
| + var o = new core.List<api.DerivedSource>();
|
| + o.add(buildDerivedSource());
|
| + o.add(buildDerivedSource());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed1533(core.List<api.DerivedSource> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkDerivedSource(o[0]);
|
| + checkDerivedSource(o[1]);
|
| +}
|
| +
|
| +buildUnnamed1534() {
|
| var o = new core.List<api.SourceSplitShard>();
|
| o.add(buildSourceSplitShard());
|
| o.add(buildSourceSplitShard());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1816(core.List<api.SourceSplitShard> o) {
|
| +checkUnnamed1534(core.List<api.SourceSplitShard> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkSourceSplitShard(o[0]);
|
| checkSourceSplitShard(o[1]);
|
| @@ -1622,8 +1777,9 @@ buildSourceSplitResponse() {
|
| var o = new api.SourceSplitResponse();
|
| buildCounterSourceSplitResponse++;
|
| if (buildCounterSourceSplitResponse < 3) {
|
| + o.bundles = buildUnnamed1533();
|
| o.outcome = "foo";
|
| - o.shards = buildUnnamed1816();
|
| + o.shards = buildUnnamed1534();
|
| }
|
| buildCounterSourceSplitResponse--;
|
| return o;
|
| @@ -1632,8 +1788,9 @@ buildSourceSplitResponse() {
|
| checkSourceSplitResponse(api.SourceSplitResponse o) {
|
| buildCounterSourceSplitResponse++;
|
| if (buildCounterSourceSplitResponse < 3) {
|
| + checkUnnamed1533(o.bundles);
|
| unittest.expect(o.outcome, unittest.equals('foo'));
|
| - checkUnnamed1816(o.shards);
|
| + checkUnnamed1534(o.shards);
|
| }
|
| buildCounterSourceSplitResponse--;
|
| }
|
| @@ -1659,30 +1816,30 @@ checkSourceSplitShard(api.SourceSplitShard o) {
|
| buildCounterSourceSplitShard--;
|
| }
|
|
|
| -buildUnnamed1817() {
|
| +buildUnnamed1535() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1817(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1535(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| - var casted32 = (o["x"]) as core.Map; unittest.expect(casted32, unittest.hasLength(3)); unittest.expect(casted32["list"], unittest.equals([1, 2, 3])); unittest.expect(casted32["bool"], unittest.equals(true)); unittest.expect(casted32["string"], unittest.equals('foo'));
|
| - var casted33 = (o["y"]) as core.Map; unittest.expect(casted33, unittest.hasLength(3)); unittest.expect(casted33["list"], unittest.equals([1, 2, 3])); unittest.expect(casted33["bool"], unittest.equals(true)); unittest.expect(casted33["string"], unittest.equals('foo'));
|
| + var casted34 = (o["x"]) as core.Map; unittest.expect(casted34, unittest.hasLength(3)); unittest.expect(casted34["list"], unittest.equals([1, 2, 3])); unittest.expect(casted34["bool"], unittest.equals(true)); unittest.expect(casted34["string"], unittest.equals('foo'));
|
| + var casted35 = (o["y"]) as core.Map; unittest.expect(casted35, unittest.hasLength(3)); unittest.expect(casted35["list"], unittest.equals([1, 2, 3])); unittest.expect(casted35["bool"], unittest.equals(true)); unittest.expect(casted35["string"], unittest.equals('foo'));
|
| }
|
|
|
| -buildUnnamed1818() {
|
| +buildUnnamed1536() {
|
| var o = new core.List<core.Map<core.String, core.Object>>();
|
| - o.add(buildUnnamed1817());
|
| - o.add(buildUnnamed1817());
|
| + o.add(buildUnnamed1535());
|
| + o.add(buildUnnamed1535());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1818(core.List<core.Map<core.String, core.Object>> o) {
|
| +checkUnnamed1536(core.List<core.Map<core.String, core.Object>> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| - checkUnnamed1817(o[0]);
|
| - checkUnnamed1817(o[1]);
|
| + checkUnnamed1535(o[0]);
|
| + checkUnnamed1535(o[1]);
|
| }
|
|
|
| core.int buildCounterStatus = 0;
|
| @@ -1691,7 +1848,7 @@ buildStatus() {
|
| buildCounterStatus++;
|
| if (buildCounterStatus < 3) {
|
| o.code = 42;
|
| - o.details = buildUnnamed1818();
|
| + o.details = buildUnnamed1536();
|
| o.message = "foo";
|
| }
|
| buildCounterStatus--;
|
| @@ -1702,23 +1859,23 @@ checkStatus(api.Status o) {
|
| buildCounterStatus++;
|
| if (buildCounterStatus < 3) {
|
| unittest.expect(o.code, unittest.equals(42));
|
| - checkUnnamed1818(o.details);
|
| + checkUnnamed1536(o.details);
|
| unittest.expect(o.message, unittest.equals('foo'));
|
| }
|
| buildCounterStatus--;
|
| }
|
|
|
| -buildUnnamed1819() {
|
| +buildUnnamed1537() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1819(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1537(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| - var casted34 = (o["x"]) as core.Map; unittest.expect(casted34, unittest.hasLength(3)); unittest.expect(casted34["list"], unittest.equals([1, 2, 3])); unittest.expect(casted34["bool"], unittest.equals(true)); unittest.expect(casted34["string"], unittest.equals('foo'));
|
| - var casted35 = (o["y"]) as core.Map; unittest.expect(casted35, unittest.hasLength(3)); unittest.expect(casted35["list"], unittest.equals([1, 2, 3])); unittest.expect(casted35["bool"], unittest.equals(true)); unittest.expect(casted35["string"], unittest.equals('foo'));
|
| + var casted36 = (o["x"]) as core.Map; unittest.expect(casted36, unittest.hasLength(3)); unittest.expect(casted36["list"], unittest.equals([1, 2, 3])); unittest.expect(casted36["bool"], unittest.equals(true)); unittest.expect(casted36["string"], unittest.equals('foo'));
|
| + var casted37 = (o["y"]) as core.Map; unittest.expect(casted37, unittest.hasLength(3)); unittest.expect(casted37["list"], unittest.equals([1, 2, 3])); unittest.expect(casted37["bool"], unittest.equals(true)); unittest.expect(casted37["string"], unittest.equals('foo'));
|
| }
|
|
|
| core.int buildCounterStep = 0;
|
| @@ -1728,7 +1885,7 @@ buildStep() {
|
| if (buildCounterStep < 3) {
|
| o.kind = "foo";
|
| o.name = "foo";
|
| - o.properties = buildUnnamed1819();
|
| + o.properties = buildUnnamed1537();
|
| }
|
| buildCounterStep--;
|
| return o;
|
| @@ -1739,7 +1896,7 @@ checkStep(api.Step o) {
|
| if (buildCounterStep < 3) {
|
| unittest.expect(o.kind, unittest.equals('foo'));
|
| unittest.expect(o.name, unittest.equals('foo'));
|
| - checkUnnamed1819(o.properties);
|
| + checkUnnamed1537(o.properties);
|
| }
|
| buildCounterStep--;
|
| }
|
| @@ -1750,6 +1907,7 @@ buildStreamLocation() {
|
| buildCounterStreamLocation++;
|
| if (buildCounterStreamLocation < 3) {
|
| o.pubsubLocation = buildPubsubLocation();
|
| + o.sideInputLocation = buildStreamingSideInputLocation();
|
| o.streamingStageLocation = buildStreamingStageLocation();
|
| }
|
| buildCounterStreamLocation--;
|
| @@ -1760,11 +1918,95 @@ checkStreamLocation(api.StreamLocation o) {
|
| buildCounterStreamLocation++;
|
| if (buildCounterStreamLocation < 3) {
|
| checkPubsubLocation(o.pubsubLocation);
|
| + checkStreamingSideInputLocation(o.sideInputLocation);
|
| checkStreamingStageLocation(o.streamingStageLocation);
|
| }
|
| buildCounterStreamLocation--;
|
| }
|
|
|
| +buildUnnamed1538() {
|
| + var o = new core.List<api.KeyRangeDataDiskAssignment>();
|
| + o.add(buildKeyRangeDataDiskAssignment());
|
| + o.add(buildKeyRangeDataDiskAssignment());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed1538(core.List<api.KeyRangeDataDiskAssignment> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkKeyRangeDataDiskAssignment(o[0]);
|
| + checkKeyRangeDataDiskAssignment(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterStreamingComputationRanges = 0;
|
| +buildStreamingComputationRanges() {
|
| + var o = new api.StreamingComputationRanges();
|
| + buildCounterStreamingComputationRanges++;
|
| + if (buildCounterStreamingComputationRanges < 3) {
|
| + o.computationId = "foo";
|
| + o.rangeAssignments = buildUnnamed1538();
|
| + }
|
| + buildCounterStreamingComputationRanges--;
|
| + return o;
|
| +}
|
| +
|
| +checkStreamingComputationRanges(api.StreamingComputationRanges o) {
|
| + buildCounterStreamingComputationRanges++;
|
| + if (buildCounterStreamingComputationRanges < 3) {
|
| + unittest.expect(o.computationId, unittest.equals('foo'));
|
| + checkUnnamed1538(o.rangeAssignments);
|
| + }
|
| + buildCounterStreamingComputationRanges--;
|
| +}
|
| +
|
| +buildUnnamed1539() {
|
| + var o = new core.List<api.StreamingComputationRanges>();
|
| + o.add(buildStreamingComputationRanges());
|
| + o.add(buildStreamingComputationRanges());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed1539(core.List<api.StreamingComputationRanges> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkStreamingComputationRanges(o[0]);
|
| + checkStreamingComputationRanges(o[1]);
|
| +}
|
| +
|
| +buildUnnamed1540() {
|
| + var o = new core.List<api.MountedDataDisk>();
|
| + o.add(buildMountedDataDisk());
|
| + o.add(buildMountedDataDisk());
|
| + return o;
|
| +}
|
| +
|
| +checkUnnamed1540(core.List<api.MountedDataDisk> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + checkMountedDataDisk(o[0]);
|
| + checkMountedDataDisk(o[1]);
|
| +}
|
| +
|
| +core.int buildCounterStreamingComputationTask = 0;
|
| +buildStreamingComputationTask() {
|
| + var o = new api.StreamingComputationTask();
|
| + buildCounterStreamingComputationTask++;
|
| + if (buildCounterStreamingComputationTask < 3) {
|
| + o.computationRanges = buildUnnamed1539();
|
| + o.dataDisks = buildUnnamed1540();
|
| + o.taskType = "foo";
|
| + }
|
| + buildCounterStreamingComputationTask--;
|
| + return o;
|
| +}
|
| +
|
| +checkStreamingComputationTask(api.StreamingComputationTask o) {
|
| + buildCounterStreamingComputationTask++;
|
| + if (buildCounterStreamingComputationTask < 3) {
|
| + checkUnnamed1539(o.computationRanges);
|
| + checkUnnamed1540(o.dataDisks);
|
| + unittest.expect(o.taskType, unittest.equals('foo'));
|
| + }
|
| + buildCounterStreamingComputationTask--;
|
| +}
|
| +
|
| core.int buildCounterStreamingSetupTask = 0;
|
| buildStreamingSetupTask() {
|
| var o = new api.StreamingSetupTask();
|
| @@ -1788,6 +2030,25 @@ checkStreamingSetupTask(api.StreamingSetupTask o) {
|
| buildCounterStreamingSetupTask--;
|
| }
|
|
|
| +core.int buildCounterStreamingSideInputLocation = 0;
|
| +buildStreamingSideInputLocation() {
|
| + var o = new api.StreamingSideInputLocation();
|
| + buildCounterStreamingSideInputLocation++;
|
| + if (buildCounterStreamingSideInputLocation < 3) {
|
| + o.tag = "foo";
|
| + }
|
| + buildCounterStreamingSideInputLocation--;
|
| + return o;
|
| +}
|
| +
|
| +checkStreamingSideInputLocation(api.StreamingSideInputLocation o) {
|
| + buildCounterStreamingSideInputLocation++;
|
| + if (buildCounterStreamingSideInputLocation < 3) {
|
| + unittest.expect(o.tag, unittest.equals('foo'));
|
| + }
|
| + buildCounterStreamingSideInputLocation--;
|
| +}
|
| +
|
| core.int buildCounterStreamingStageLocation = 0;
|
| buildStreamingStageLocation() {
|
| var o = new api.StreamingStageLocation();
|
| @@ -1807,14 +2068,14 @@ checkStreamingStageLocation(api.StreamingStageLocation o) {
|
| buildCounterStreamingStageLocation--;
|
| }
|
|
|
| -buildUnnamed1820() {
|
| +buildUnnamed1541() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1820(core.List<core.String> o) {
|
| +checkUnnamed1541(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'));
|
| @@ -1836,7 +2097,7 @@ buildTaskRunnerSettings() {
|
| o.logDir = "foo";
|
| o.logToSerialconsole = true;
|
| o.logUploadLocation = "foo";
|
| - o.oauthScopes = buildUnnamed1820();
|
| + o.oauthScopes = buildUnnamed1541();
|
| o.parallelWorkerSettings = buildWorkerSettings();
|
| o.streamingWorkerMainClass = "foo";
|
| o.taskGroup = "foo";
|
| @@ -1863,7 +2124,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'));
|
| - checkUnnamed1820(o.oauthScopes);
|
| + checkUnnamed1541(o.oauthScopes);
|
| checkWorkerSettings(o.parallelWorkerSettings);
|
| unittest.expect(o.streamingWorkerMainClass, unittest.equals('foo'));
|
| unittest.expect(o.taskGroup, unittest.equals('foo'));
|
| @@ -1875,27 +2136,27 @@ checkTaskRunnerSettings(api.TaskRunnerSettings o) {
|
| buildCounterTaskRunnerSettings--;
|
| }
|
|
|
| -buildUnnamed1821() {
|
| +buildUnnamed1542() {
|
| var o = new core.List<api.ComputationTopology>();
|
| o.add(buildComputationTopology());
|
| o.add(buildComputationTopology());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1821(core.List<api.ComputationTopology> o) {
|
| +checkUnnamed1542(core.List<api.ComputationTopology> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkComputationTopology(o[0]);
|
| checkComputationTopology(o[1]);
|
| }
|
|
|
| -buildUnnamed1822() {
|
| +buildUnnamed1543() {
|
| var o = new core.List<api.DataDiskAssignment>();
|
| o.add(buildDataDiskAssignment());
|
| o.add(buildDataDiskAssignment());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1822(core.List<api.DataDiskAssignment> o) {
|
| +checkUnnamed1543(core.List<api.DataDiskAssignment> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkDataDiskAssignment(o[0]);
|
| checkDataDiskAssignment(o[1]);
|
| @@ -1906,8 +2167,8 @@ buildTopologyConfig() {
|
| var o = new api.TopologyConfig();
|
| buildCounterTopologyConfig++;
|
| if (buildCounterTopologyConfig < 3) {
|
| - o.computations = buildUnnamed1821();
|
| - o.dataDiskAssignments = buildUnnamed1822();
|
| + o.computations = buildUnnamed1542();
|
| + o.dataDiskAssignments = buildUnnamed1543();
|
| }
|
| buildCounterTopologyConfig--;
|
| return o;
|
| @@ -1916,20 +2177,20 @@ buildTopologyConfig() {
|
| checkTopologyConfig(api.TopologyConfig o) {
|
| buildCounterTopologyConfig++;
|
| if (buildCounterTopologyConfig < 3) {
|
| - checkUnnamed1821(o.computations);
|
| - checkUnnamed1822(o.dataDiskAssignments);
|
| + checkUnnamed1542(o.computations);
|
| + checkUnnamed1543(o.dataDiskAssignments);
|
| }
|
| buildCounterTopologyConfig--;
|
| }
|
|
|
| -buildUnnamed1823() {
|
| +buildUnnamed1544() {
|
| var o = new core.List<api.Package>();
|
| o.add(buildPackage());
|
| o.add(buildPackage());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1823(core.List<api.Package> o) {
|
| +checkUnnamed1544(core.List<api.Package> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkPackage(o[0]);
|
| checkPackage(o[1]);
|
| @@ -1942,15 +2203,17 @@ buildWorkItem() {
|
| if (buildCounterWorkItem < 3) {
|
| o.configuration = "foo";
|
| o.id = "foo";
|
| + o.initialReportIndex = "foo";
|
| o.jobId = "foo";
|
| o.leaseExpireTime = "foo";
|
| o.mapTask = buildMapTask();
|
| - o.packages = buildUnnamed1823();
|
| + o.packages = buildUnnamed1544();
|
| o.projectId = "foo";
|
| o.reportStatusInterval = "foo";
|
| o.seqMapTask = buildSeqMapTask();
|
| o.shellTask = buildShellTask();
|
| o.sourceOperationTask = buildSourceOperationRequest();
|
| + o.streamingComputationTask = buildStreamingComputationTask();
|
| o.streamingSetupTask = buildStreamingSetupTask();
|
| }
|
| buildCounterWorkItem--;
|
| @@ -1962,31 +2225,33 @@ checkWorkItem(api.WorkItem o) {
|
| if (buildCounterWorkItem < 3) {
|
| unittest.expect(o.configuration, unittest.equals('foo'));
|
| unittest.expect(o.id, unittest.equals('foo'));
|
| + unittest.expect(o.initialReportIndex, unittest.equals('foo'));
|
| unittest.expect(o.jobId, unittest.equals('foo'));
|
| unittest.expect(o.leaseExpireTime, unittest.equals('foo'));
|
| checkMapTask(o.mapTask);
|
| - checkUnnamed1823(o.packages);
|
| + checkUnnamed1544(o.packages);
|
| unittest.expect(o.projectId, unittest.equals('foo'));
|
| unittest.expect(o.reportStatusInterval, unittest.equals('foo'));
|
| checkSeqMapTask(o.seqMapTask);
|
| checkShellTask(o.shellTask);
|
| checkSourceOperationRequest(o.sourceOperationTask);
|
| + checkStreamingComputationTask(o.streamingComputationTask);
|
| checkStreamingSetupTask(o.streamingSetupTask);
|
| }
|
| buildCounterWorkItem--;
|
| }
|
|
|
| -buildUnnamed1824() {
|
| +buildUnnamed1545() {
|
| 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;
|
| }
|
|
|
| -checkUnnamed1824(core.Map<core.String, core.Object> o) {
|
| +checkUnnamed1545(core.Map<core.String, core.Object> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| - var casted36 = (o["x"]) as core.Map; unittest.expect(casted36, unittest.hasLength(3)); unittest.expect(casted36["list"], unittest.equals([1, 2, 3])); unittest.expect(casted36["bool"], unittest.equals(true)); unittest.expect(casted36["string"], unittest.equals('foo'));
|
| - var casted37 = (o["y"]) as core.Map; unittest.expect(casted37, unittest.hasLength(3)); unittest.expect(casted37["list"], unittest.equals([1, 2, 3])); unittest.expect(casted37["bool"], unittest.equals(true)); unittest.expect(casted37["string"], unittest.equals('foo'));
|
| + var casted38 = (o["x"]) as core.Map; unittest.expect(casted38, unittest.hasLength(3)); unittest.expect(casted38["list"], unittest.equals([1, 2, 3])); unittest.expect(casted38["bool"], unittest.equals(true)); unittest.expect(casted38["string"], unittest.equals('foo'));
|
| + var casted39 = (o["y"]) as core.Map; unittest.expect(casted39, unittest.hasLength(3)); unittest.expect(casted39["list"], unittest.equals([1, 2, 3])); unittest.expect(casted39["bool"], unittest.equals(true)); unittest.expect(casted39["string"], unittest.equals('foo'));
|
| }
|
|
|
| core.int buildCounterWorkItemServiceState = 0;
|
| @@ -1994,8 +2259,9 @@ buildWorkItemServiceState() {
|
| var o = new api.WorkItemServiceState();
|
| buildCounterWorkItemServiceState++;
|
| if (buildCounterWorkItemServiceState < 3) {
|
| - o.harnessData = buildUnnamed1824();
|
| + o.harnessData = buildUnnamed1545();
|
| o.leaseExpireTime = "foo";
|
| + o.nextReportIndex = "foo";
|
| o.reportStatusInterval = "foo";
|
| o.suggestedStopPoint = buildApproximateProgress();
|
| o.suggestedStopPosition = buildPosition();
|
| @@ -2007,8 +2273,9 @@ buildWorkItemServiceState() {
|
| checkWorkItemServiceState(api.WorkItemServiceState o) {
|
| buildCounterWorkItemServiceState++;
|
| if (buildCounterWorkItemServiceState < 3) {
|
| - checkUnnamed1824(o.harnessData);
|
| + checkUnnamed1545(o.harnessData);
|
| unittest.expect(o.leaseExpireTime, unittest.equals('foo'));
|
| + unittest.expect(o.nextReportIndex, unittest.equals('foo'));
|
| unittest.expect(o.reportStatusInterval, unittest.equals('foo'));
|
| checkApproximateProgress(o.suggestedStopPoint);
|
| checkPosition(o.suggestedStopPosition);
|
| @@ -2016,27 +2283,27 @@ checkWorkItemServiceState(api.WorkItemServiceState o) {
|
| buildCounterWorkItemServiceState--;
|
| }
|
|
|
| -buildUnnamed1825() {
|
| +buildUnnamed1546() {
|
| var o = new core.List<api.Status>();
|
| o.add(buildStatus());
|
| o.add(buildStatus());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1825(core.List<api.Status> o) {
|
| +checkUnnamed1546(core.List<api.Status> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkStatus(o[0]);
|
| checkStatus(o[1]);
|
| }
|
|
|
| -buildUnnamed1826() {
|
| +buildUnnamed1547() {
|
| var o = new core.List<api.MetricUpdate>();
|
| o.add(buildMetricUpdate());
|
| o.add(buildMetricUpdate());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1826(core.List<api.MetricUpdate> o) {
|
| +checkUnnamed1547(core.List<api.MetricUpdate> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkMetricUpdate(o[0]);
|
| checkMetricUpdate(o[1]);
|
| @@ -2048,8 +2315,9 @@ buildWorkItemStatus() {
|
| buildCounterWorkItemStatus++;
|
| if (buildCounterWorkItemStatus < 3) {
|
| o.completed = true;
|
| - o.errors = buildUnnamed1825();
|
| - o.metricUpdates = buildUnnamed1826();
|
| + o.dynamicSourceSplit = buildDynamicSourceSplit();
|
| + o.errors = buildUnnamed1546();
|
| + o.metricUpdates = buildUnnamed1547();
|
| o.progress = buildApproximateProgress();
|
| o.reportIndex = "foo";
|
| o.requestedLeaseDuration = "foo";
|
| @@ -2066,8 +2334,9 @@ checkWorkItemStatus(api.WorkItemStatus o) {
|
| buildCounterWorkItemStatus++;
|
| if (buildCounterWorkItemStatus < 3) {
|
| unittest.expect(o.completed, unittest.isTrue);
|
| - checkUnnamed1825(o.errors);
|
| - checkUnnamed1826(o.metricUpdates);
|
| + checkDynamicSourceSplit(o.dynamicSourceSplit);
|
| + checkUnnamed1546(o.errors);
|
| + checkUnnamed1547(o.metricUpdates);
|
| checkApproximateProgress(o.progress);
|
| unittest.expect(o.reportIndex, unittest.equals('foo'));
|
| unittest.expect(o.requestedLeaseDuration, unittest.equals('foo'));
|
| @@ -2079,61 +2348,75 @@ checkWorkItemStatus(api.WorkItemStatus o) {
|
| buildCounterWorkItemStatus--;
|
| }
|
|
|
| -buildUnnamed1827() {
|
| +buildUnnamed1548() {
|
| var o = new core.List<api.Disk>();
|
| o.add(buildDisk());
|
| o.add(buildDisk());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1827(core.List<api.Disk> o) {
|
| +checkUnnamed1548(core.List<api.Disk> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkDisk(o[0]);
|
| checkDisk(o[1]);
|
| }
|
|
|
| -buildUnnamed1828() {
|
| +buildUnnamed1549() {
|
| var o = new core.Map<core.String, core.String>();
|
| o["x"] = "foo";
|
| o["y"] = "foo";
|
| return o;
|
| }
|
|
|
| -checkUnnamed1828(core.Map<core.String, core.String> o) {
|
| +checkUnnamed1549(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'));
|
| }
|
|
|
| -buildUnnamed1829() {
|
| +buildUnnamed1550() {
|
| var o = new core.List<api.Package>();
|
| o.add(buildPackage());
|
| o.add(buildPackage());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1829(core.List<api.Package> o) {
|
| +checkUnnamed1550(core.List<api.Package> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkPackage(o[0]);
|
| checkPackage(o[1]);
|
| }
|
|
|
| +buildUnnamed1551() {
|
| + 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;
|
| +}
|
| +
|
| +checkUnnamed1551(core.Map<core.String, core.Object> o) {
|
| + unittest.expect(o, unittest.hasLength(2));
|
| + var casted40 = (o["x"]) as core.Map; unittest.expect(casted40, unittest.hasLength(3)); unittest.expect(casted40["list"], unittest.equals([1, 2, 3])); unittest.expect(casted40["bool"], unittest.equals(true)); unittest.expect(casted40["string"], unittest.equals('foo'));
|
| + var casted41 = (o["y"]) as core.Map; unittest.expect(casted41, unittest.hasLength(3)); unittest.expect(casted41["list"], unittest.equals([1, 2, 3])); unittest.expect(casted41["bool"], unittest.equals(true)); unittest.expect(casted41["string"], unittest.equals('foo'));
|
| +}
|
| +
|
| core.int buildCounterWorkerPool = 0;
|
| buildWorkerPool() {
|
| var o = new api.WorkerPool();
|
| buildCounterWorkerPool++;
|
| if (buildCounterWorkerPool < 3) {
|
| o.autoscalingSettings = buildAutoscalingSettings();
|
| - o.dataDisks = buildUnnamed1827();
|
| + o.dataDisks = buildUnnamed1548();
|
| o.defaultPackageSet = "foo";
|
| o.diskSizeGb = 42;
|
| o.diskSourceImage = "foo";
|
| o.kind = "foo";
|
| o.machineType = "foo";
|
| - o.metadata = buildUnnamed1828();
|
| + o.metadata = buildUnnamed1549();
|
| o.numWorkers = 42;
|
| o.onHostMaintenance = "foo";
|
| - o.packages = buildUnnamed1829();
|
| + o.packages = buildUnnamed1550();
|
| + o.poolArgs = buildUnnamed1551();
|
| o.taskrunnerSettings = buildTaskRunnerSettings();
|
| o.teardownPolicy = "foo";
|
| o.zone = "foo";
|
| @@ -2146,16 +2429,17 @@ checkWorkerPool(api.WorkerPool o) {
|
| buildCounterWorkerPool++;
|
| if (buildCounterWorkerPool < 3) {
|
| checkAutoscalingSettings(o.autoscalingSettings);
|
| - checkUnnamed1827(o.dataDisks);
|
| + checkUnnamed1548(o.dataDisks);
|
| unittest.expect(o.defaultPackageSet, unittest.equals('foo'));
|
| unittest.expect(o.diskSizeGb, unittest.equals(42));
|
| unittest.expect(o.diskSourceImage, unittest.equals('foo'));
|
| unittest.expect(o.kind, unittest.equals('foo'));
|
| unittest.expect(o.machineType, unittest.equals('foo'));
|
| - checkUnnamed1828(o.metadata);
|
| + checkUnnamed1549(o.metadata);
|
| unittest.expect(o.numWorkers, unittest.equals(42));
|
| unittest.expect(o.onHostMaintenance, unittest.equals('foo'));
|
| - checkUnnamed1829(o.packages);
|
| + checkUnnamed1550(o.packages);
|
| + checkUnnamed1551(o.poolArgs);
|
| checkTaskRunnerSettings(o.taskrunnerSettings);
|
| unittest.expect(o.teardownPolicy, unittest.equals('foo'));
|
| unittest.expect(o.zone, unittest.equals('foo'));
|
| @@ -2251,6 +2535,15 @@ main() {
|
| });
|
|
|
|
|
| + unittest.group("obj-schema-DerivedSource", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildDerivedSource();
|
| + var od = new api.DerivedSource.fromJson(o.toJson());
|
| + checkDerivedSource(od);
|
| + });
|
| + });
|
| +
|
| +
|
| unittest.group("obj-schema-Disk", () {
|
| unittest.test("to-json--from-json", () {
|
| var o = buildDisk();
|
| @@ -2260,6 +2553,15 @@ main() {
|
| });
|
|
|
|
|
| + unittest.group("obj-schema-DynamicSourceSplit", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildDynamicSourceSplit();
|
| + var od = new api.DynamicSourceSplit.fromJson(o.toJson());
|
| + checkDynamicSourceSplit(od);
|
| + });
|
| + });
|
| +
|
| +
|
| unittest.group("obj-schema-Environment", () {
|
| unittest.test("to-json--from-json", () {
|
| var o = buildEnvironment();
|
| @@ -2341,6 +2643,15 @@ main() {
|
| });
|
|
|
|
|
| + unittest.group("obj-schema-KeyRangeDataDiskAssignment", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildKeyRangeDataDiskAssignment();
|
| + var od = new api.KeyRangeDataDiskAssignment.fromJson(o.toJson());
|
| + checkKeyRangeDataDiskAssignment(od);
|
| + });
|
| + });
|
| +
|
| +
|
| unittest.group("obj-schema-KeyRangeLocation", () {
|
| unittest.test("to-json--from-json", () {
|
| var o = buildKeyRangeLocation();
|
| @@ -2413,6 +2724,15 @@ main() {
|
| });
|
|
|
|
|
| + unittest.group("obj-schema-MountedDataDisk", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildMountedDataDisk();
|
| + var od = new api.MountedDataDisk.fromJson(o.toJson());
|
| + checkMountedDataDisk(od);
|
| + });
|
| + });
|
| +
|
| +
|
| unittest.group("obj-schema-MultiOutputInfo", () {
|
| unittest.test("to-json--from-json", () {
|
| var o = buildMultiOutputInfo();
|
| @@ -2674,6 +2994,24 @@ main() {
|
| });
|
|
|
|
|
| + unittest.group("obj-schema-StreamingComputationRanges", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStreamingComputationRanges();
|
| + var od = new api.StreamingComputationRanges.fromJson(o.toJson());
|
| + checkStreamingComputationRanges(od);
|
| + });
|
| + });
|
| +
|
| +
|
| + unittest.group("obj-schema-StreamingComputationTask", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStreamingComputationTask();
|
| + var od = new api.StreamingComputationTask.fromJson(o.toJson());
|
| + checkStreamingComputationTask(od);
|
| + });
|
| + });
|
| +
|
| +
|
| unittest.group("obj-schema-StreamingSetupTask", () {
|
| unittest.test("to-json--from-json", () {
|
| var o = buildStreamingSetupTask();
|
| @@ -2683,6 +3021,15 @@ main() {
|
| });
|
|
|
|
|
| + unittest.group("obj-schema-StreamingSideInputLocation", () {
|
| + unittest.test("to-json--from-json", () {
|
| + var o = buildStreamingSideInputLocation();
|
| + var od = new api.StreamingSideInputLocation.fromJson(o.toJson());
|
| + checkStreamingSideInputLocation(od);
|
| + });
|
| + });
|
| +
|
| +
|
| unittest.group("obj-schema-StreamingStageLocation", () {
|
| unittest.test("to-json--from-json", () {
|
| var o = buildStreamingStageLocation();
|
| @@ -2767,7 +3114,7 @@ main() {
|
| unittest.group("resource-V1b3ProjectsJobsResourceApi", () {
|
| unittest.test("method--create", () {
|
|
|
| - var mock = new common_test.HttpServerMock();
|
| + var mock = new HttpServerMock();
|
| api.V1b3ProjectsJobsResourceApi res = new api.DataflowApi(mock).v1b3.projects.jobs;
|
| var arg_request = buildJob();
|
| var arg_projectId = "foo";
|
| @@ -2806,7 +3153,7 @@ main() {
|
| "content-type" : "application/json; charset=utf-8",
|
| };
|
| var resp = convert.JSON.encode(buildJob());
|
| - return new async.Future.value(common_test.stringResponse(200, h, resp));
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| res.create(arg_request, arg_projectId, view: arg_view).then(unittest.expectAsync(((api.Job response) {
|
| checkJob(response);
|
| @@ -2815,7 +3162,7 @@ main() {
|
|
|
| unittest.test("method--get", () {
|
|
|
| - var mock = new common_test.HttpServerMock();
|
| + var mock = new HttpServerMock();
|
| api.V1b3ProjectsJobsResourceApi res = new api.DataflowApi(mock).v1b3.projects.jobs;
|
| var arg_projectId = "foo";
|
| var arg_jobId = "foo";
|
| @@ -2851,7 +3198,7 @@ main() {
|
| "content-type" : "application/json; charset=utf-8",
|
| };
|
| var resp = convert.JSON.encode(buildJob());
|
| - return new async.Future.value(common_test.stringResponse(200, h, resp));
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| res.get(arg_projectId, arg_jobId, view: arg_view).then(unittest.expectAsync(((api.Job response) {
|
| checkJob(response);
|
| @@ -2860,7 +3207,7 @@ main() {
|
|
|
| unittest.test("method--getMetrics", () {
|
|
|
| - var mock = new common_test.HttpServerMock();
|
| + var mock = new HttpServerMock();
|
| api.V1b3ProjectsJobsResourceApi res = new api.DataflowApi(mock).v1b3.projects.jobs;
|
| var arg_projectId = "foo";
|
| var arg_jobId = "foo";
|
| @@ -2896,7 +3243,7 @@ main() {
|
| "content-type" : "application/json; charset=utf-8",
|
| };
|
| var resp = convert.JSON.encode(buildJobMetrics());
|
| - return new async.Future.value(common_test.stringResponse(200, h, resp));
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| res.getMetrics(arg_projectId, arg_jobId, startTime: arg_startTime).then(unittest.expectAsync(((api.JobMetrics response) {
|
| checkJobMetrics(response);
|
| @@ -2905,7 +3252,7 @@ main() {
|
|
|
| unittest.test("method--list", () {
|
|
|
| - var mock = new common_test.HttpServerMock();
|
| + var mock = new HttpServerMock();
|
| api.V1b3ProjectsJobsResourceApi res = new api.DataflowApi(mock).v1b3.projects.jobs;
|
| var arg_projectId = "foo";
|
| var arg_pageSize = 42;
|
| @@ -2944,7 +3291,7 @@ main() {
|
| "content-type" : "application/json; charset=utf-8",
|
| };
|
| var resp = convert.JSON.encode(buildListJobsResponse());
|
| - return new async.Future.value(common_test.stringResponse(200, h, resp));
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| res.list(arg_projectId, pageSize: arg_pageSize, pageToken: arg_pageToken, view: arg_view).then(unittest.expectAsync(((api.ListJobsResponse response) {
|
| checkListJobsResponse(response);
|
| @@ -2953,7 +3300,7 @@ main() {
|
|
|
| unittest.test("method--patch", () {
|
|
|
| - var mock = new common_test.HttpServerMock();
|
| + var mock = new HttpServerMock();
|
| api.V1b3ProjectsJobsResourceApi res = new api.DataflowApi(mock).v1b3.projects.jobs;
|
| var arg_request = buildJob();
|
| var arg_projectId = "foo";
|
| @@ -2991,7 +3338,7 @@ main() {
|
| "content-type" : "application/json; charset=utf-8",
|
| };
|
| var resp = convert.JSON.encode(buildJob());
|
| - return new async.Future.value(common_test.stringResponse(200, h, resp));
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| res.patch(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.Job response) {
|
| checkJob(response);
|
| @@ -3000,7 +3347,7 @@ main() {
|
|
|
| unittest.test("method--update", () {
|
|
|
| - var mock = new common_test.HttpServerMock();
|
| + var mock = new HttpServerMock();
|
| api.V1b3ProjectsJobsResourceApi res = new api.DataflowApi(mock).v1b3.projects.jobs;
|
| var arg_request = buildJob();
|
| var arg_projectId = "foo";
|
| @@ -3038,7 +3385,7 @@ main() {
|
| "content-type" : "application/json; charset=utf-8",
|
| };
|
| var resp = convert.JSON.encode(buildJob());
|
| - return new async.Future.value(common_test.stringResponse(200, h, resp));
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| res.update(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.Job response) {
|
| checkJob(response);
|
| @@ -3051,7 +3398,7 @@ main() {
|
| unittest.group("resource-V1b3ProjectsJobsMessagesResourceApi", () {
|
| unittest.test("method--list", () {
|
|
|
| - var mock = new common_test.HttpServerMock();
|
| + var mock = new HttpServerMock();
|
| api.V1b3ProjectsJobsMessagesResourceApi res = new api.DataflowApi(mock).v1b3.projects.jobs.messages;
|
| var arg_projectId = "foo";
|
| var arg_jobId = "foo";
|
| @@ -3095,7 +3442,7 @@ main() {
|
| "content-type" : "application/json; charset=utf-8",
|
| };
|
| var resp = convert.JSON.encode(buildListJobMessagesResponse());
|
| - return new async.Future.value(common_test.stringResponse(200, h, resp));
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| res.list(arg_projectId, arg_jobId, endTime: arg_endTime, minimumImportance: arg_minimumImportance, pageSize: arg_pageSize, pageToken: arg_pageToken, startTime: arg_startTime).then(unittest.expectAsync(((api.ListJobMessagesResponse response) {
|
| checkListJobMessagesResponse(response);
|
| @@ -3108,7 +3455,7 @@ main() {
|
| unittest.group("resource-V1b3ProjectsJobsWorkItemsResourceApi", () {
|
| unittest.test("method--lease", () {
|
|
|
| - var mock = new common_test.HttpServerMock();
|
| + var mock = new HttpServerMock();
|
| api.V1b3ProjectsJobsWorkItemsResourceApi res = new api.DataflowApi(mock).v1b3.projects.jobs.workItems;
|
| var arg_request = buildLeaseWorkItemRequest();
|
| var arg_projectId = "foo";
|
| @@ -3146,7 +3493,7 @@ main() {
|
| "content-type" : "application/json; charset=utf-8",
|
| };
|
| var resp = convert.JSON.encode(buildLeaseWorkItemResponse());
|
| - return new async.Future.value(common_test.stringResponse(200, h, resp));
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| res.lease(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.LeaseWorkItemResponse response) {
|
| checkLeaseWorkItemResponse(response);
|
| @@ -3155,7 +3502,7 @@ main() {
|
|
|
| unittest.test("method--reportStatus", () {
|
|
|
| - var mock = new common_test.HttpServerMock();
|
| + var mock = new HttpServerMock();
|
| api.V1b3ProjectsJobsWorkItemsResourceApi res = new api.DataflowApi(mock).v1b3.projects.jobs.workItems;
|
| var arg_request = buildReportWorkItemStatusRequest();
|
| var arg_projectId = "foo";
|
| @@ -3193,7 +3540,7 @@ main() {
|
| "content-type" : "application/json; charset=utf-8",
|
| };
|
| var resp = convert.JSON.encode(buildReportWorkItemStatusResponse());
|
| - return new async.Future.value(common_test.stringResponse(200, h, resp));
|
| + return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| res.reportStatus(arg_request, arg_projectId, arg_jobId).then(unittest.expectAsync(((api.ReportWorkItemStatusResponse response) {
|
| checkReportWorkItemStatusResponse(response);
|
|
|
Chromium Code Reviews
Issue 1078053002:
Roll of googleapis as of 4/7/2015. (Closed)
Base URL: https://github.com/dart-lang/googleapis.git@master