Add close procedures to Kafka test

kubeshop · Aug 21, 2023 · d070670 · d070670
1 parent 675f188
commit d070670
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/testing/cli-e2etest/environment/manager.go b/testing/cli-e2etest/environment/manager.go
@@ -219,10 +219,15 @@ func (m *internalManager) Close(t *testing.T) {
 	}
 
 	if m.pokeshopEnabled {
+		pokeshopDockerComposeFile := m.dockerComposePokeshopFilePath
+		if m.pokeshopStreamEnabled {
+			pokeshopDockerComposeFile = m.dockerComposePokeshopWithStreamFilepath
+		}
+
 		args = []string{
 			"compose",
 			"--file", m.dockerComposeNoApiFilePath, // choose docker compose relative to the chosen environment
-			"--file", m.dockerComposePokeshopFilePath, // choose docker compose relative to the chosen environment
+			"--file", pokeshopDockerComposeFile, // choose docker compose relative to the chosen environment
 			"--project-name", m.dockerProjectName, // choose isolated project name
 			"rm",
 			"--force",   // bypass removal question