You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by he...@apache.org on 2021/10/25 12:27:52 UTC

[brooklyn-server] 01/15: attach feed poll tasks to the feeds so they are visible in the ui

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 a214e1f0c10016e70a33e014728339c765efdf5f
Author: Alex Heneveld <al...@cloudsoftcorp.com>
AuthorDate: Wed Oct 20 10:13:26 2021 +0100

    attach feed poll tasks to the feeds so they are visible in the ui
---
 core/src/main/java/org/apache/brooklyn/core/feed/Poller.java            | 1 +
 .../src/main/java/org/apache/brooklyn/util/core/task/ScheduledTask.java | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/core/src/main/java/org/apache/brooklyn/core/feed/Poller.java b/core/src/main/java/org/apache/brooklyn/core/feed/Poller.java
index 2d70baa..97b7a6b 100644
--- a/core/src/main/java/org/apache/brooklyn/core/feed/Poller.java
+++ b/core/src/main/java/org/apache/brooklyn/core/feed/Poller.java
@@ -162,6 +162,7 @@ public class Poller<V> {
                         .displayName("scheduled:" + scheduleName)
                         .period(pollJob.pollPeriod)
                         .cancelOnException(false)
+                        .tag(feed!=null ? BrooklynTaskTags.tagForContextAdjunct(feed) : null)
                         .build();
                 tasks.add(Entities.submit(entity, t));
                 if (minPeriod==null || (pollJob.pollPeriod.isShorterThan(minPeriod))) {
diff --git a/core/src/main/java/org/apache/brooklyn/util/core/task/ScheduledTask.java b/core/src/main/java/org/apache/brooklyn/util/core/task/ScheduledTask.java
index b6a7029..3b23ac2 100644
--- a/core/src/main/java/org/apache/brooklyn/util/core/task/ScheduledTask.java
+++ b/core/src/main/java/org/apache/brooklyn/util/core/task/ScheduledTask.java
@@ -155,7 +155,7 @@ public class ScheduledTask extends BasicTask<Object> {
         }
         
         public Builder displayName(String val) { this.displayName = val; return this; }
-        public Builder tag(Object val) { this.tags.add(val); return this; }
+        public Builder tag(Object val) { if (val!=null) this.tags.add(val); return this; }
         public Builder tagTransient() { return tag(BrooklynTaskTags.TRANSIENT_TASK_TAG); }
         public Builder delay(Duration val) { this.delay = val; return this; }
         public Builder period(Duration val) { this.period = val; return this; }