Migrated execution verification to shared

Shuffle · Apr 12, 2021 · 8fd8006 · 8fd8006
1 parent ae168d0
commit 8fd8006
Show file tree

Hide file tree

Showing 3 changed files with 692 additions and 14 deletions.
diff --git a/db-connector.go b/db-connector.go
@@ -206,7 +206,7 @@ func SetWorkflowExecution(ctx context.Context, workflowExecution WorkflowExecuti
 			log.Printf("[WARNING] Failed updating execution cache: %s", err)
 		}
 	} else {
-		log.Printf("[INFO] Set execution cache for workflowexecution %s", cacheKey)
+		//log.Printf("[INFO] Set execution cache for workflowexecution %s", cacheKey)
 	}
 
 	//requestCache.Set(cacheKey, &workflowExecution, cache.DefaultExpiration)
@@ -225,17 +225,6 @@ func SetWorkflowExecution(ctx context.Context, workflowExecution WorkflowExecuti
 	return nil
 }
 
-type ExecutionVariableWrapper struct {
-	StartNode    string              `json:"startnode"`
-	Children     map[string][]string `json:"children"`
-	Parents      map[string][]string `json:"parents""`
-	Visited      []string            `json:"visited"`
-	Executed     []string            `json:"executed"`
-	NextActions  []string            `json:"nextActions"`
-	Environments []string            `json:"environments"`
-	Extra        int                 `json:"extra"`
-}
-
 // Initializes an execution's extra variables
 func SetInitExecutionVariables(ctx context.Context, workflowExecution WorkflowExecution) {
 	environments := []string{}