response = checkMethodBase(searchBody).get(API_PATH + "/logs").asString();
        List<Map<String, Object>> afterLogs = JsonPath.from(response).getList("response.logs");

        boolean logDeleted = afterLogs.stream().noneMatch(log -> logId.equals(log.get("id").toString()));
        assertTrue(logDeleted, "Log should be deleted");

        logger.info("[END] testDeleteFailureUrlLog");
    }

    /**

                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                } finally {
                    doneLatch.countDown();
                }
            });
        }

        startLatch.countDown();
        assertTrue(doneLatch.await(30, TimeUnit.SECONDS));
        executor.shutdown();

        // Drain remaining
        totalDrained.addAndGet(helper.drainAll().size());

                () -> {
                  startLatch.countDown();
                  startLatch.await();
                  callable.call();
                  doneLatch.countDown();
                  return null;
                });
      }
      doneLatch.await();
    } finally {
      executorService.shutdown();
    }
  }

                () -> {
                  startLatch.countDown();
                  startLatch.await();
                  callable.call();
                  doneLatch.countDown();
                  return null;
                });
      }
      doneLatch.await();
    } finally {
      executorService.shutdown();
    }
  }

                    Thread.currentThread().interrupt();
                } finally {
                    doneLatch.countDown();
                }
            }).start();
        }

        startLatch.countDown();
        doneLatch.await();

        // Verify all items were polled exactly once
        assertEquals(itemsPerThread * numThreads, totalPolled.get());

                } catch (InterruptedException ignore) {} finally {
                    doneLatch.countDown();
                }
            }).start();
        }

        startLatch.countDown(); // Start all threads
        assertTrue("All threads should complete", doneLatch.await(10, TimeUnit.SECONDS));

        Thread.sleep(100); // Wait for callback to execute