Fix for the expendable proxies (#2103)

Barthelemy · web-flow · commit 8d777ac6860b · 2024-01-24T17:25:39.000+01:00
diff --git a/Framework/src/InfrastructureGenerator.cxx b/Framework/src/InfrastructureGenerator.cxx
@@ -580,7 +580,7 @@ void InfrastructureGenerator::generateLocalTaskRemoteProxy(framework::WorkflowSp
     dplModelAdaptor());
   proxy.labels.emplace_back(taskSpec.localControl == "odc" ? ecs::preserveRawChannelsLabel : ecs::uniqueProxyLabel);
   if (!taskSpec.critical) {
-    workflow.back().labels.emplace_back(framework::DataProcessorLabel{ "expendable" });
+    proxy.labels.emplace_back(framework::DataProcessorLabel{ "expendable" });
   }
   // if not in RUNNING, we should drop all the incoming messages, we set the corresponding proxy option.
   enableDraining(proxy.options);

Original file line number	Diff line number	Diff line change
`@@ -580,7 +580,7 @@ void InfrastructureGenerator::generateLocalTaskRemoteProxy(framework::WorkflowSp`
`580`	`580`	`dplModelAdaptor());`
`581`	`581`	`proxy.labels.emplace_back(taskSpec.localControl == "odc" ? ecs::preserveRawChannelsLabel : ecs::uniqueProxyLabel);`
`582`	`582`	`if (!taskSpec.critical) {`
`583`		`- workflow.back().labels.emplace_back(framework::DataProcessorLabel{ "expendable" });`
	`583`	`+ proxy.labels.emplace_back(framework::DataProcessorLabel{ "expendable" });`
`584`	`584`	`}`
`585`	`585`	`// if not in RUNNING, we should drop all the incoming messages, we set the corresponding proxy option.`
`586`	`586`	`enableDraining(proxy.options);`