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 <[email protected]> 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;
