From f55db57fcec350ab5742d0613593578e7be79754 Mon Sep 17 00:00:00 2001
From: joshvanl <me@joshvanl.dev>
Date: Tue, 1 Aug 2023 01:38:13 +0100
Subject: [PATCH] docker-compose logs on up error

Signed-off-by: joshvanl <me@joshvanl.dev>
---
 .../flow/dockercompose/dockercompose.go          |  8 ++++++++
 tests/certification/pubsub/pulsar/pulsar_test.go | 16 ++++++++--------
 2 files changed, 16 insertions(+), 8 deletions(-)

diff --git a/tests/certification/flow/dockercompose/dockercompose.go b/tests/certification/flow/dockercompose/dockercompose.go
index b1b6666047..7faa87d592 100644
--- a/tests/certification/flow/dockercompose/dockercompose.go
+++ b/tests/certification/flow/dockercompose/dockercompose.go
@@ -56,6 +56,13 @@ func (c Compose) Up(ctx flow.Context) error {
 		"--remove-orphans").CombinedOutput()
 	ctx.Log(string(out))
 
+	out, lerr := exec.Command(
+		"docker-compose",
+		"-f", c.filename,
+		"logs").CombinedOutput()
+	ctx.Log(lerr)
+	ctx.Log(string(out))
+
 	return err
 }
 
@@ -68,6 +75,7 @@ func (c Compose) Down(ctx flow.Context) error {
 		"docker-compose",
 		"-f", c.filename,
 		"logs").CombinedOutput()
+	ctx.Log(err)
 	ctx.Log(string(out))
 
 	out, err = exec.Command(
diff --git a/tests/certification/pubsub/pulsar/pulsar_test.go b/tests/certification/pubsub/pulsar/pulsar_test.go
index 3adb199781..e37e0ed30e 100644
--- a/tests/certification/pubsub/pulsar/pulsar_test.go
+++ b/tests/certification/pubsub/pulsar/pulsar_test.go
@@ -106,14 +106,14 @@ type pulsarSuite struct {
 }
 
 func TestPulsar(t *testing.T) {
-	t.Run("Auth:None", func(t *testing.T) {
-		suite.Run(t, &pulsarSuite{
-			authType:          "none",
-			dockerComposeYAML: dockerComposeAuthNoneYAML,
-			componentsPath:    "./components/auth-none",
-			services:          []string{"standalone"},
-		})
-	})
+	//t.Run("Auth:None", func(t *testing.T) {
+	//	suite.Run(t, &pulsarSuite{
+	//		authType:          "none",
+	//		dockerComposeYAML: dockerComposeAuthNoneYAML,
+	//		componentsPath:    "./components/auth-none",
+	//		services:          []string{"standalone"},
+	//	})
+	//})
 
 	t.Run("Auth:OIDC", func(t *testing.T) {
 		t.Log("Starting OIDC server...")