new PROFILES_SUBSET config parame

gradle.properties

@@ -1,2 +1,2 @@
 group=org.ceskaexpedice
-version=1.3
+version=1.4-dev

process-worker/src/main/java/org/ceskaexpedice/processplatform/worker/WorkerMain.java

@@ -70,10 +70,31 @@ private List<PluginInfo> scanPlugins() {
 
     private void registerNode(List<PluginInfo> pluginsList) {
         LOGGER.info(String.format("Register node [%s]", workerConfiguration.getWorkerId()));
-        Set<String> tags = new HashSet<>();
+        // Supported profiles from plugins
+        Set<String> supportedProfiles = new HashSet<>();
         for (PluginInfo pluginInfo : pluginsList) {
-            for (PluginProfile pluginProfile: pluginInfo.getProfiles()){
-                tags.add(pluginProfile.getProfileId());
+            for (PluginProfile pluginProfile : pluginInfo.getProfiles()) {
+                supportedProfiles.add(pluginProfile.getProfileId());
+            }
+        }
+        // Configured subset
+        Set<String> configuredSubset = workerConfiguration.getProfilesSubset();
+        Set<String> tags;
+        if (configuredSubset.isEmpty()) {
+            // No filtering configured → use all supported
+            tags = supportedProfiles;
+        } else {
+            tags = new HashSet<>();
+            for (String profile : configuredSubset) {
+                if (supportedProfiles.contains(profile)) {
+                    tags.add(profile);
+                } else {
+                    LOGGER.warning(String.format(
+                            "Profile [%s] configured in %s is not supported by this worker",
+                            profile,
+                            WorkerConfiguration.PROFILES_SUBSET_KEY
+                    ));
+                }
             }
         }
         Node node = new Node();
@@ -82,7 +103,6 @@ private void registerNode(List<PluginInfo> pluginsList) {
         node.setType(NodeType.WORKER);
         node.setUrl(workerConfiguration.getWorkerBaseUrl());
         node.setTags(tags);
-
         managerClient.registerNode(node);
     }
 

process-worker/src/main/java/org/ceskaexpedice/processplatform/worker/config/WorkerConfiguration.java

@@ -18,10 +18,8 @@
 
 import java.io.File;
 import java.nio.charset.StandardCharsets;
-import java.util.Base64;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Properties;
+import java.util.*;
+import java.util.stream.Collectors;
 
 import static org.ceskaexpedice.processplatform.worker.utils.Utils.parseSimpleJson;
 
@@ -41,6 +39,7 @@ public class WorkerConfiguration {
     private static final String MANAGER_BASE_URL_KEY = "MANAGER_BASE_URL";
     private static final String WORKER_BASE_URL_KEY = "WORKER_BASE_URL";
     private static final String WORKER_ID_KEY = "WORKER_ID";
+    public static final String PROFILES_SUBSET_KEY = "PROFILES_SUBSET";
 
     private final Properties props = new Properties();
 
@@ -141,6 +140,17 @@ public String getManagerBaseUrl() {
         return "http://localhost:8080/";
     }
 
+    public Set<String> getProfilesSubset() {
+        String subsetValue = get(WorkerConfiguration.PROFILES_SUBSET_KEY);
+        if (subsetValue == null || subsetValue.isBlank()) {
+            return Collections.emptySet();
+        }
+        return Arrays.stream(subsetValue.split(","))
+                .map(String::trim)
+                .filter(s -> !s.isEmpty())
+                .collect(Collectors.toSet());
+    }
+
     public void setManagerBaseUrl(String  managerBaseUrl) {
         set(MANAGER_BASE_URL_KEY, managerBaseUrl);
     }

process-worker/src/main/resources/worker.properties

@@ -2,3 +2,4 @@ MANAGER_BASE_URL=-none-
 WORKER_BASE_URL=-none-
 WORKER_ID=-none-
 WORKER_LOOP_SLEEP_SECS=10
+#PROFILES_SUBSET=profile1,profile2