[brooklyn-server] 01/02: fix failing test -- relied on tag in overly restrictive way

[he...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

heneveld pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/brooklyn-server.git

commit d2fd0dcc86a08d7fe42f4e633085db29aaa34c89
Author: Alex Heneveld <al...@cloudsoft.io>
AuthorDate: Mon Jun 27 15:30:22 2022 +0100

    fix failing test -- relied on tag in overly restrictive way
---
 .../apache/brooklyn/camp/brooklyn/AbstractJcloudsStubYamlTest.java | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/camp/camp-brooklyn/src/test/java/org/apache/brooklyn/camp/brooklyn/AbstractJcloudsStubYamlTest.java b/camp/camp-brooklyn/src/test/java/org/apache/brooklyn/camp/brooklyn/AbstractJcloudsStubYamlTest.java
index 6f9277a1f7..0b02f4c6b5 100644
--- a/camp/camp-brooklyn/src/test/java/org/apache/brooklyn/camp/brooklyn/AbstractJcloudsStubYamlTest.java
+++ b/camp/camp-brooklyn/src/test/java/org/apache/brooklyn/camp/brooklyn/AbstractJcloudsStubYamlTest.java
@@ -22,6 +22,7 @@ import static com.google.common.base.Preconditions.checkNotNull;
 
 import java.io.Reader;
 import java.util.Set;
+import java.util.stream.Collectors;
 
 import org.apache.brooklyn.api.entity.Entity;
 import org.apache.brooklyn.api.mgmt.Task;
@@ -163,8 +164,10 @@ public abstract class AbstractJcloudsStubYamlTest extends AbstractJcloudsStubbed
         // wait for app to have started
         Set<Task<?>> tasks = mgmt().getExecutionManager().getTasksWithAllTags(ImmutableList.of(
                 BrooklynTaskTags.EFFECTOR_TAG, 
-                BrooklynTaskTags.tagForContextEntity(app), 
-                BrooklynTaskTags.tagForEffectorCall(app, "start", ConfigBag.newInstance(ImmutableMap.of("locations", ImmutableMap.of())))));
+                BrooklynTaskTags.tagForContextEntity(app))).stream().filter(task ->
+                    task.getTags().stream().filter(tag ->
+                        tag instanceof BrooklynTaskTags.EffectorCallTag && ((BrooklynTaskTags.EffectorCallTag)tag).getEffectorName().equals("start")
+                    ).findAny().isPresent()).collect(Collectors.toSet());
         Iterables.getOnlyElement(tasks).get();
         
         return app;