azkaban-aplcache

Having setExpireCondition to help products relying on azkaban

6/1/2017 3:20:21 PM
3.25.1

Details

diff --git a/azkaban-common/src/main/java/azkaban/trigger/Trigger.java b/azkaban-common/src/main/java/azkaban/trigger/Trigger.java
index 1bf12ed..c88cd82 100644
--- a/azkaban-common/src/main/java/azkaban/trigger/Trigger.java
+++ b/azkaban-common/src/main/java/azkaban/trigger/Trigger.java
@@ -34,10 +34,12 @@ public class Trigger {
   private final long submitTime;
   private final String submitUser;
   private final String source;
-  private final Condition triggerCondition;
-  private final Condition expireCondition;
   private final List<TriggerAction> actions;
   private final List<TriggerAction> expireActions;
+  
+  private Condition expireCondition;
+  private Condition triggerCondition;
+  
   private int triggerId = -1;
   private long lastModifyTime;
   private TriggerStatus status = TriggerStatus.READY;
@@ -213,10 +215,18 @@ public class Trigger {
     return triggerCondition;
   }
 
+  public void setTriggerCondition(Condition triggerCondition) {
+    this.triggerCondition = triggerCondition;
+  }
+
   public Condition getExpireCondition() {
     return expireCondition;
   }
 
+  public void setExpireCondition(Condition expireCondition) {
+    this.expireCondition = expireCondition;
+  }
+
   public List<TriggerAction> getActions() {
     return actions;
   }