@@ -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