issue-11979 - WIP - Fixed tests

Signed-off-by: Helber Belmiro <[email protected]>

Author: hbelmiro

backend/test/v2/integration/dag_status_conditional_test.go

@@ -59,7 +59,12 @@ func (s *DAGStatusConditionalTestSuite) createUploadParams(testName, filePath st
 	pipelineName := fmt.Sprintf("%s_test", testName)
 	displayName := fmt.Sprintf("%s Test Pipeline", testName)
 	description := fmt.Sprintf("Test pipeline for %s scenario", testName)
+	
+	// Use resourceNamespace if available (Kubeflow mode), otherwise use kubeflow namespace
 	namespace := s.resourceNamespace
+	if namespace == "" {
+		namespace = "kubeflow"
+	}
 
 	uploadParams.SetName(&pipelineName)
 	uploadParams.SetDisplayName(&displayName) 

backend/test/v2/integration/dag_status_nested_test.go

@@ -41,7 +41,12 @@ func (s *DAGStatusNestedTestSuite) createUploadParams(testName, filePath string)
 	pipelineName := fmt.Sprintf("%s_test", testName)
 	displayName := fmt.Sprintf("%s Test Pipeline", testName)
 	description := fmt.Sprintf("Test pipeline for %s scenario", testName)
+	
+	// Use resourceNamespace if available (Kubeflow mode), otherwise use kubeflow namespace
 	namespace := s.resourceNamespace
+	if namespace == "" {
+		namespace = "kubeflow"
+	}
 
 	uploadParams.SetName(&pipelineName)
 	uploadParams.SetDisplayName(&displayName) 

backend/test/v2/integration/dag_status_parallel_for_test.go

@@ -57,7 +57,12 @@ func (s *DAGStatusParallelForTestSuite) createUploadParams(testName, filePath st
 	pipelineName := fmt.Sprintf("%s_test", testName)
 	displayName := fmt.Sprintf("%s Test Pipeline", testName)
 	description := fmt.Sprintf("Test pipeline for %s scenario", testName)
+	
+	// Use resourceNamespace if available (Kubeflow mode), otherwise use kubeflow namespace
 	namespace := s.resourceNamespace
+	if namespace == "" {
+		namespace = "kubeflow"
+	}
 
 	uploadParams.SetName(&pipelineName)
 	uploadParams.SetDisplayName(&displayName)