Merge pull request #859 from shital-orchestral/task-retry-model-branch

Added  task retry model feature to task properties.

Author: m4dcoder

modules/st2-auto-form/style.css

@@ -482,5 +482,3 @@
 }
 
 
-
-

modules/st2flow-details/orquesta-properties.js

@@ -62,6 +62,11 @@ export default class OrquestaTransition extends Component<TransitionProps, {}> {
     }
   }
 
+  getValue(value) {
+    console.log("getValue called",value);
+    if(!isNaN(value) && value!== '') value = parseInt(value,10);
+    return value;
+  }
   style = style
   joinFieldRef = React.createRef();
 
@@ -100,6 +105,17 @@ export default class OrquestaTransition extends Component<TransitionProps, {}> {
           )
         }
       </Property>,
+      <Property key="retry" name="Retry" description="Define the retry condition for the task execution." value={!!task.retry} onChange={value => this.handleTaskProperty('retry', value ? { when: '<% failed() %>' } : false)}>
+        {
+          task.retry && (
+            <div className={this.style.propertyChild}>
+              <StringField name="when" value={task.retry.when} className="when-title" onChange={value => this.handleTaskProperty([ 'retry', 'when' ], value)} spec={{'default':'enter expression'}}  />
+              <StringField name="count" value={task.retry.count} className="count-title" onChange={value => this.handleTaskProperty([ 'retry', 'count' ], this.getValue(value))}  spec={{'default':'enter expression or integer'}} />
+              <StringField name="delay (seconds)" value={task.retry.delay} className="delay-title" onChange={value => this.handleTaskProperty([ 'retry', 'delay'], this.getValue(value))} spec={{'default':'enter expression or integer'}} />
+            </div>
+          )
+}
+      </Property>,
       <Property key="with" name="With Items" description="Run an action or workflow associated with a task multiple times." value={!!task.with} onChange={value => this.handleTaskProperty('with', value ? { items: 'x in <% ctx(y) %>' } : false)}>
         {
           task.with && (

modules/st2flow-model/interfaces.js

@@ -40,6 +40,11 @@ export interface TaskInterface {
         items: string,
         concurrency?: string,
     };
+    retry?: ?{
+        when: string,
+        count?: string,
+        delay?: string,
+    };
     join?: ?string;
     ref?: any;
 }

modules/st2flow-model/model-orquesta.js

@@ -87,7 +87,8 @@ type RawTask = {
   input?: Object,
   next?: Array<NextItem>,
   with?: string | Object,
-  join?: string
+  join?: string,
+  retry?:string | Object
 };
 
 type RawTasks = {
@@ -140,7 +141,7 @@ class OrquestaModel extends BaseModel implements ModelInterface {
         }
       }
 
-      const { action = '', input, 'with': _with, join } = task;
+      const { action = '', input, 'with': _with,'retry': _retry, join } = task;
       const [ actionRef, ...inputPartials ] = `${action}`.split(' ');
 
       // if (inputPartials.length) {
@@ -162,6 +163,7 @@ class OrquestaModel extends BaseModel implements ModelInterface {
         },
         with: typeof _with === 'string' ? { items: _with } : _with,
         join,
+        retry: typeof _retry === 'string' ?{ when: _retry} : _retry,
       };
 
       return retVal;

modules/st2flow-model/schemas/orquesta.json

@@ -51,6 +51,43 @@
                 }
               }
             },
+            "retry": {
+              "type": "object",
+              "properties": {
+                "when": {
+                  "type": "string",
+                  "minLength": 1
+                },
+                "count": {
+                  "oneOf": [
+                    {
+                      "type": "string",
+                      "minLength": 1
+                    },
+                    {
+                      "type": "integer",
+                      "minimum": 0
+                    }
+                  ]
+                },
+                "delay": {
+                  "oneOf": [
+                    {
+                      "type": "string",
+                      "minLength": 1
+                    },
+                    {
+                      "type": "integer",
+                      "minimum": 0
+                    }
+                  ]
+                }
+              },
+              "required": [
+                "count"
+              ],
+              "additionalProperties": false
+            },
             "input": {
               "oneOf": [
                 {
@@ -327,4 +364,4 @@
       "type": "string"
     }
   }
-}
+}