fix: log retry logic (#6211)

Signed-off-by: Vladislav Sukhin <vladislav@kubeshop.io>
kubeshop · Mar 3, 2025 · 2320f92 · 2320f92
1 parent f40a951
commit 2320f92
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/cmd/kubectl-testkube/commands/testworkflows/run.go b/cmd/kubectl-testkube/commands/testworkflows/run.go
@@ -430,7 +430,8 @@ func watchTestWorkflowLogs(id string, signature []testkube.TestWorkflowSignature
 
 			// Check if result stream is closed and if execution is finished
 			result = printTestWorkflowLogs(signature, notifications)
-			if result != nil && result.Status != nil && *result.Status != testkube.RUNNING_TestWorkflowStatus {
+			if result != nil && result.Status != nil &&
+				(*result.Status == testkube.QUEUED_TestWorkflowStatus || *result.Status == testkube.RUNNING_TestWorkflowStatus) {
 				return fmt.Errorf("test workflow execution is not finished but channel is closed")
 			}