Added code for skipping execution irrespective of the activity has ou…

…tput or not (#194)
project-flogo · Feb 5, 2024 · dce3eed · dce3eed
1 parent cfb6cae
commit dce3eed
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 8 deletions.
diff --git a/instance/util.go b/instance/util.go
@@ -198,7 +198,7 @@ func hasOutputInterceptor(taskInst *TaskInst) bool {
 
 		id := taskInst.flowInst.Name() + "-" + taskInst.task.ID()
 		taskInterceptor := master.interceptor.GetTaskInterceptor(id)
-		if taskInterceptor != nil && len(taskInterceptor.Outputs) > 0 {
+		if taskInterceptor != nil && taskInterceptor.SkipExecution {
 			return true
 		}
 	}

diff --git a/support/interceptor.go b/support/interceptor.go
@@ -45,13 +45,14 @@ func (pi *Interceptor) GetTaskInterceptor(taskID string) *TaskInterceptor {
 // Also, a 'Skip' flag can be enabled to inform the runtime that the task should not
 // execute.
 type TaskInterceptor struct {
-	ID         string                 `json:"id"`
-	Skip       bool                   `json:"skip,omitempty"`
-	Inputs     map[string]interface{} `json:"inputs,omitempty"`
-	Outputs    map[string]interface{} `json:"outputs,omitempty"`
-	Assertions []Assertion            `json:"assertions,omitempty"`
-	Result     int                    `json:"result,omitempty"`
-	Message    string                 `json:"message"`
+	ID            string                 `json:"id"`
+	Skip          bool                   `json:"skip,omitempty"`
+	Inputs        map[string]interface{} `json:"inputs,omitempty"`
+	Outputs       map[string]interface{} `json:"outputs,omitempty"`
+	Assertions    []Assertion            `json:"assertions,omitempty"`
+	SkipExecution bool                   `json:"skipExecution"`
+	Result        int                    `json:"result,omitempty"`
+	Message       string                 `json:"message"`
 }
 
 type Assertion struct {