Catch known exceptions (broken pipe)

quarkus-test-core/src/main/java/io/quarkus/test/bootstrap/QuarkusScenarioBootstrap.java

@@ -12,6 +12,7 @@
 
 import jakarta.inject.Inject;
 
+import org.junit.jupiter.api.Assumptions;
 import org.junit.jupiter.api.extension.AfterAllCallback;
 import org.junit.jupiter.api.extension.AfterEachCallback;
 import org.junit.jupiter.api.extension.BeforeAllCallback;
@@ -26,6 +27,7 @@
 import io.quarkus.test.configuration.PropertyLookup;
 import io.quarkus.test.logging.Log;
 import io.quarkus.test.services.quarkus.ProdQuarkusApplicationManagedResourceBuilder;
+import io.quarkus.test.utils.KnownExceptionChecker;
 import io.quarkus.test.utils.ReflectionUtils;
 
 public class QuarkusScenarioBootstrap
@@ -168,6 +170,18 @@ private void launchService(Service service) {
         extensions.forEach(ext -> ext.onServiceLaunch(scenario, service));
         try {
             service.start();
+        } catch (RuntimeException runtimeException) {
+            // catch known failures is service launch.
+            // mostly searching for "Broken pipe" failure - https://github.com/quarkusio/quarkus/issues/38334
+            if (KnownExceptionChecker.checkForKnownException(runtimeException)) {
+                Log.error("Known exception catched, printing it");
+                runtimeException.printStackTrace();
+                // abort test execution
+                Assumptions.abort();
+            } else {
+                scenarioOnError(runtimeException);
+                throw runtimeException;
+            }
         } catch (Throwable throwable) {
             scenarioOnError(throwable);
             throw throwable;

quarkus-test-core/src/main/java/io/quarkus/test/listener/QuarkusTestExceptionFilter.java

@@ -0,0 +1,29 @@
+package io.quarkus.test.listener;
+
+import org.junit.jupiter.api.Assumptions;
+import org.junit.jupiter.api.extension.ExtensionContext;
+import org.junit.jupiter.api.extension.TestExecutionExceptionHandler;
+
+import io.quarkus.test.logging.Log;
+import io.quarkus.test.utils.KnownExceptionChecker;
+
+/**
+ * Extension is masking exceptions, caused by known issues which cannot be easily disabled.
+ * Originally created for <a href="https://github.com/quarkusio/quarkus/issues/38334">Broken pipe</a> issue.
+ * In case that related exception is thrown, this extension will swallow it, and make test marked as skipped.
+ */
+public class QuarkusTestExceptionFilter implements TestExecutionExceptionHandler {
+
+    @Override
+    public void handleTestExecutionException(ExtensionContext context, Throwable throwable) throws Throwable {
+        // if exception is caused by known issue, swallow it, otherwise propagate it
+        if (KnownExceptionChecker.checkForKnownException(throwable)) {
+            Log.error("Skipping test " + context.getDisplayName() + " known exception found. Printing stack trace");
+            throwable.printStackTrace();
+            // skip the test
+            Assumptions.abort();
+        } else {
+            throw throwable;
+        }
+    }
+}

quarkus-test-core/src/main/java/io/quarkus/test/scenarios/QuarkusScenario.java

@@ -9,12 +9,14 @@
 import org.junit.jupiter.api.extension.ExtendWith;
 
 import io.quarkus.test.bootstrap.QuarkusScenarioBootstrap;
+import io.quarkus.test.listener.QuarkusTestExceptionFilter;
 import io.quarkus.test.scenarios.execution.condition.QuarkusScenarioExecutionConditions;
 
 @Target(ElementType.TYPE)
 @Retention(RetentionPolicy.RUNTIME)
 @ExtendWith(QuarkusScenarioBootstrap.class)
 @ExtendWith(QuarkusScenarioExecutionConditions.class)
+@ExtendWith(QuarkusTestExceptionFilter.class)
 @Inherited
 public @interface QuarkusScenario {
 }

quarkus-test-core/src/main/java/io/quarkus/test/utils/KnownExceptionChecker.java

@@ -0,0 +1,35 @@
+package io.quarkus.test.utils;
+
+import java.util.List;
+
+public final class KnownExceptionChecker {
+    /**
+     * List of known exception messages. If you want to mask any exception, add its message here
+     */
+    private static final List<String> KNOWN_EXCEPTION_MESSAGES = List.of("Broken pipe");
+
+    private KnownExceptionChecker() {
+    }
+
+    /**
+     * Check if thrown message contains any of the known exception messages.
+     * Method is recursive, it will check the exception itself and all causes and suppressed ones as well.
+     *
+     * @param throwable Exception to check
+     * @return true if any known exception message is included, false otherwise
+     */
+    public static boolean checkForKnownException(Throwable throwable) {
+        if (KNOWN_EXCEPTION_MESSAGES.stream().anyMatch(throwable.getMessage()::contains)) {
+            return true;
+        }
+        if (throwable.getCause() != null && checkForKnownException(throwable.getCause())) {
+            return true;
+        }
+        for (Throwable t : throwable.getSuppressed()) {
+            if (checkForKnownException(t)) {
+                return true;
+            }
+        }
+        return false;
+    }
+}

quarkus-test-openshift/src/main/java/io/quarkus/test/scenarios/OpenShiftScenario.java

@@ -9,11 +9,13 @@
 import org.junit.jupiter.api.extension.ExtendWith;
 
 import io.quarkus.test.bootstrap.QuarkusScenarioBootstrap;
+import io.quarkus.test.listener.QuarkusTestExceptionFilter;
 import io.quarkus.test.services.Operator;
 
 @Target(ElementType.TYPE)
 @Retention(RetentionPolicy.RUNTIME)
 @ExtendWith(QuarkusScenarioBootstrap.class)
+@ExtendWith(QuarkusTestExceptionFilter.class)
 @Inherited
 public @interface OpenShiftScenario {
     OpenShiftDeploymentStrategy deployment() default OpenShiftDeploymentStrategy.Build;