Merge pull request #229 from orkes-io/task_caching

Task Execution Cache

Author: v1r3n

common/src/main/java/com/netflix/conductor/common/metadata/workflow/WorkflowTask.java

@@ -151,6 +151,12 @@ public void setTasks(List<WorkflowTask> tasks) {
     @ProtoField(id = 29)
     private String joinStatus;
 
+    @ProtoField(id = 30)
+    private Map<String, Object> cacheKey = new HashMap<>();
+
+    @ProtoField(id = 31)
+    private long cacheTTL;
+
     /*
     Map of events to be emitted when the task status changed.
     key can be comma separated values of the status changes prefixed with "on"<STATUS>
@@ -392,6 +398,22 @@ public void setScriptExpression(String expression) {
         this.scriptExpression = expression;
     }
 
+    public Map<String, Object> getCacheKey() {
+        return cacheKey;
+    }
+
+    public void setCacheKey(Map<String, Object> cacheKey) {
+        this.cacheKey = cacheKey;
+    }
+
+    public long getCacheTTL() {
+        return cacheTTL;
+    }
+
+    public void setCacheTTL(long cacheTTL) {
+        this.cacheTTL = cacheTTL;
+    }
+
     /**
      * @return the subWorkflow
      */