assertEquals("Python Process terminated.", e.getMessage());
            assertNotNull(e.getCause());
            // Check cause message if available, otherwise just verify cause exists
            if (e.getCause().getMessage() != null) {
                assertTrue(e.getCause().getMessage().contains("Process start failed"));
            }
        }
    }

    checkMessage(expected, "LockB -> LockA", "LockA -> LockB");
    // The causal chain should be cached.
    assertThat(expected.getCause()).isEqualTo(firstException.getCause());
    // lockA should work after lockB is released.
    lockB.unlock();
    lockA.lock();
  }

  // Tests transitive deadlock detection.
  public void testDeadlock_threeLocks() {

    checkMessage(expected, "LockB -> LockA", "LockA -> LockB");
    // The causal chain should be cached.
    assertThat(expected.getCause()).isEqualTo(firstException.getCause());
    // lockA should work after lockB is released.
    lockB.unlock();
    lockA.lock();
  }

  // Tests transitive deadlock detection.
  public void testDeadlock_threeLocks() {

  @Override
  public V getUnchecked(K key) {
    try {
      return get(key);
    } catch (ExecutionException e) {
      throw new UncheckedExecutionException(e.getCause());
    }
  }

  @Override
  public ImmutableMap<K, V> getAll(Iterable<? extends K> keys) throws ExecutionException {
    Map<K, V> result = new LinkedHashMap<>();
    for (K key : keys) {

        // Test with root cause
        Exception rootCause = new Exception("Root cause");
        DcerpcException ex3 = new DcerpcException("Error with cause", rootCause);
        assertEquals(rootCause, ex3.getCause());
    }

    @Test
    @DisplayName("Should verify error message lookup for known fault codes")
    void testErrorMessageLookup() {
        // Test message lookup using DcerpcException's static method

       * exist but throw, so we propagate anything that's thrown, presumably an unchecked Exception
       * or Error.
       */
      throwIfUnchecked(e.getCause());
      throw new AssertionError(e.getCause());
    }
  }

              Object returnValue = method.invoke(delegate, args);
              mutateDelegate();
              return returnValue;
            } catch (InvocationTargetException e) {
              throw e.getCause();
            } catch (IllegalAccessException e) {
              throw new AssertionError(e);
            }
          }

          private void mutateDelegate() {

        initRepoSession(configuration);

        try {
            return projectBuilder.build(pom, configuration).getProject();
        } catch (Exception e) {
            Throwable cause = e.getCause();
            if (cause instanceof ModelBuildingException modelBuildingException) {
                StringBuilder message = new StringBuilder("In: " + pom + "\n\n");

        } catch (JobProcessingException e) {
            assertTrue(e.getMessage().contains("Failed to execute a crawl job"));
            assertNotNull(e.getCause());
            assertEquals("Test exception", e.getCause().getMessage());
        }
    }

    // Test execute with JobProcessingException in executeCrawler
    @Test

    BadFuture badInput = new BadFuture(immediateFuture(20));
    ListenableFuture<String> chain = buildChainingFuture(badInput);
    ExecutionException e = assertThrows(ExecutionException.class, chain::get);
    assertThat(e.getCause()).isInstanceOf(BadFutureRuntimeException.class);
  }

  /** Proxy to throw a {@link RuntimeException} out of the {@link #get()} method. */
  public static class BadFuture extends SimpleForwardingListenableFuture<Integer> {