fix(cache): Cache executions with no outputs. Fixes #3507 (#3808)

Fixes #3507
kubeflow · Aug 21, 2020 · 40353bf · 40353bf
1 parent fe21cd2
commit 40353bf
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/backend/src/cache/server/watcher.go b/backend/src/cache/server/watcher.go
@@ -53,12 +53,13 @@ func WatchPods(namespaceToWatch string, clientManager ClientManagerInterface) {
 				continue
 			}
 
-			executionOutput, exists := pod.ObjectMeta.Annotations[ArgoWorkflowOutputs]
-			executionKey := pod.ObjectMeta.Annotations[ExecutionKey]
+			executionKey, exists := pod.ObjectMeta.Annotations[ExecutionKey]
 			if !exists {
 				continue
 			}
 
+			executionOutput, exists := pod.ObjectMeta.Annotations[ArgoWorkflowOutputs]
+
 			executionOutputMap := make(map[string]interface{})
 			executionOutputMap[ArgoWorkflowOutputs] = executionOutput
 			executionOutputMap[MetadataExecutionIDKey] = pod.ObjectMeta.Labels[MetadataExecutionIDKey]