assertTrue(result.contains("3 docs"));
        // queryBuilder field is protected, so we can't directly assert it
    }

    // Test execute() method with exception handling
    public void test_execute_withException() {
        // Register a mock that throws exception
        SearchEngineClient exceptionClient = new SearchEngineClient() {
            @Override
            public long updateByQuery(String index,

        String result = aggregateLogJob.execute();

        // Verify result is empty string on success
        assertNotNull(result);
        assertEquals("", result);
    }

    public void test_execute_withException() {
        // Setup mock SearchLogHelper that throws exception
        final String errorMessage = "Test exception occurred";
        SearchLogHelper mockSearchLogHelper = new SearchLogHelper() {
            @Override

        assertEquals("now", rangeQuery.to());

        // Assert result is empty when successful
        assertEquals("", result);
    }

    public void test_execute_withException() {
        // Create mock SearchEngineClient that throws exception
        searchEngineClient = new SearchEngineClient() {
            @Override

        assertTrue(result.contains("TestScoreBooster : 100"));
        assertTrue(result.contains("TestScoreBooster : 200"));
    }

    // Test execute with exception in booster
    public void test_execute_withException() {
        TestScoreBooster booster1 = new TestScoreBooster(100L);
        ExceptionScoreBooster booster2 = new ExceptionScoreBooster();
        TestScoreBooster booster3 = new TestScoreBooster(300L);

                assertTrue(e.getCause().getMessage().contains("Process start failed"));
            }
        }
    }

    // Test execute with exception handling
    public void test_execute_withException() {
        pythonJob.filename("test.py");

        testProcessHelper.throwException = new RuntimeException("Unexpected error");

        String result = pythonJob.execute();

        assertNotNull(thumbnailJob.sessionId);
        assertTrue(result.contains("Session Id: " + thumbnailJob.sessionId));
    }

    // Test execute with exception
    public void test_execute_withException() {
        thumbnailJob.numOfThreads(2);

        testProcessHelper.throwException = new RuntimeException("Unexpected error");

        String result = thumbnailJob.execute();

        // Test with minimum timeout
        execJob.timeout(Integer.MIN_VALUE);
        assertEquals(Integer.MIN_VALUE, execJob.timeout);
    }

    // Test exception handling in execute
    public void test_execute_withException() {
        execJob.setThrowException(true);

        try {
            execJob.execute();
            fail("Should throw RuntimeException");
        } catch (RuntimeException e) {