Skip to content

Commit 402a76a

Browse files
authored
[QC-584] Local QC workflows should appears as indentical to AliECS (#804)
1 parent 77e7eed commit 402a76a

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

Framework/src/InfrastructureGenerator.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -400,7 +400,7 @@ void InfrastructureGenerator::generateLocalTaskLocalProxy(framework::WorkflowSpe
400400
std::string taskName, std::string remoteHost,
401401
std::string remotePort, const std::string& control)
402402
{
403-
std::string proxyName = taskName + "-proxy-" + std::to_string(id);
403+
std::string proxyName = taskName + "-proxy";
404404
std::string channelName = taskName + "-proxy";
405405
InputSpec proxyInput{ channelName, TaskRunner::createTaskDataOrigin(), TaskRunner::createTaskDataDescription(taskName), static_cast<SubSpec>(id) };
406406
std::string channelConfig = "name=" + channelName + ",type=push,method=connect,address=tcp://" +

Framework/test/testInfrastructureGenerator.cxx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ BOOST_AUTO_TEST_CASE(qc_factory_local_test)
4242
BOOST_CHECK_EQUAL(workflow[0].outputs.size(), 1);
4343
BOOST_CHECK_EQUAL(DataSpecUtils::getOptionalSubSpec(workflow[0].outputs[0]).value_or(-1), 1);
4444

45-
BOOST_CHECK_EQUAL(workflow[1].name, "skeletonTask-proxy-1");
45+
BOOST_CHECK_EQUAL(workflow[1].name, "skeletonTask-proxy");
4646
BOOST_CHECK_EQUAL(workflow[1].inputs.size(), 1);
4747
BOOST_CHECK_EQUAL(DataSpecUtils::getOptionalSubSpec(workflow[1].inputs[0]).value_or(-1), 1);
4848
BOOST_CHECK_EQUAL(workflow[1].outputs.size(), 0);
@@ -62,7 +62,7 @@ BOOST_AUTO_TEST_CASE(qc_factory_local_test)
6262
BOOST_CHECK_EQUAL(workflow[0].outputs.size(), 1);
6363
BOOST_CHECK_EQUAL(DataSpecUtils::getOptionalSubSpec(workflow[0].outputs[0]).value_or(-1), 2);
6464

65-
BOOST_CHECK_EQUAL(workflow[1].name, "skeletonTask-proxy-2");
65+
BOOST_CHECK_EQUAL(workflow[1].name, "skeletonTask-proxy");
6666
BOOST_CHECK_EQUAL(workflow[1].inputs.size(), 1);
6767
BOOST_CHECK_EQUAL(DataSpecUtils::getOptionalSubSpec(workflow[1].inputs[0]).value_or(-1), 2);
6868
BOOST_CHECK_EQUAL(workflow[1].outputs.size(), 0);

0 commit comments

Comments
 (0)