Skip to content

Commit b76f9f5

Browse files
committed
fix tests
1 parent 0aadcaf commit b76f9f5

1 file changed

Lines changed: 27 additions & 3 deletions

File tree

Framework/test/testInfrastructureGenerator.cxx

Lines changed: 27 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,15 @@ TEST_CASE("qc_factory_remote_test")
190190
return d.name.find("qc-check") != std::string::npos &&
191191
d.inputs.size() == 1;
192192
});
193-
REQUIRE(checkRunnerCount == 6);
193+
REQUIRE(checkRunnerCount == 4);
194+
195+
auto checkSinkCount = std::count_if(
196+
workflow.begin(), workflow.end(),
197+
[](const DataProcessorSpec& d) {
198+
return d.name.find("qc-sink") != std::string::npos &&
199+
d.inputs.size() == 1;
200+
});
201+
REQUIRE(checkSinkCount == 2);
194202

195203
auto postprocessingTask = std::find_if(
196204
workflow.begin(), workflow.end(),
@@ -272,7 +280,15 @@ TEST_CASE("qc_factory_standalone_test")
272280
return d.name.find("qc-check") != std::string::npos &&
273281
d.inputs.size() == 1;
274282
});
275-
REQUIRE(checkRunnerCount == 5);
283+
REQUIRE(checkRunnerCount == 4);
284+
285+
auto checkSinkCount = std::count_if(
286+
workflow.begin(), workflow.end(),
287+
[](const DataProcessorSpec& d) {
288+
return d.name.find("qc-sink") != std::string::npos &&
289+
d.inputs.size() == 1;
290+
});
291+
REQUIRE(checkSinkCount == 1);
276292

277293
auto postprocessingTask = std::find_if(
278294
workflow.begin(), workflow.end(),
@@ -411,7 +427,15 @@ TEST_CASE("qc_infrastructure_remote_batch_test")
411427
return d.name.find("qc-check") != std::string::npos &&
412428
d.inputs.size() == 1;
413429
});
414-
REQUIRE(checkRunnerCount == 6);
430+
REQUIRE(checkRunnerCount == 4);
431+
432+
auto checkSinkCount = std::count_if(
433+
workflow.begin(), workflow.end(),
434+
[](const DataProcessorSpec& d) {
435+
return d.name.find("qc-sink") != std::string::npos &&
436+
d.inputs.size() == 1;
437+
});
438+
REQUIRE(checkSinkCount == 2);
415439

416440
auto postprocessingTask = std::find_if(
417441
workflow.begin(), workflow.end(),

0 commit comments

Comments
 (0)