fail("Should throw JobProcessingException");
        } 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

    @Test
    public void test_executePython_blankFilename() {
        pythonJob.filename("");

        try {
            pythonJob.executePython();
            fail("Should throw JobProcessingException");
        } catch (JobProcessingException e) {
            assertEquals("Python script is not specified.", e.getMessage());
        }
    }

    // Test executePython with null filename
    @Test

            final Object result = script.run();
            logScriptExecution(template, "success");
            return result;
        } catch (final JobProcessingException e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Script raised JobProcessingException", e);
            }
            logScriptExecution(template, "failure:" + e.getClass().getSimpleName());
            throw e;

            purgeExpiry = expiry;
            if (throwException) {
                if (exceptionMessage != null) {
                    throw new JobProcessingException(new RuntimeException(exceptionMessage));
                }
                throw new JobProcessingException(new RuntimeException("Test exception"));
            }
            return purgeCallCount;
        }

        public void setPurgeCallCount(long count) {

        try {
            testEngine.evaluate("throw new org.codelibs.fess.exception.JobProcessingException('test')", params);
            fail("Expected JobProcessingException");
        } catch (final JobProcessingException e) {
            assertTrue(testEngine.logScriptExecutionCalled);
            assertEquals("failure:JobProcessingException", testEngine.lastLoggedResult);
        }
    }

    /**

        testProcessHelper.processOutput = "Generation failed";

        try {
            thumbnailJob.executeThumbnailGenerator();
            fail("Should throw JobProcessingException");
        } catch (JobProcessingException e) {
            assertTrue(e.getMessage().contains("Thumbnail Process terminated."));
        } catch (NullPointerException e) {
            // May occur if ServletContext is not fully initialized

 */
package org.codelibs.fess.indexer;

import java.util.HashMap;
import java.util.Map;

import org.codelibs.fess.Constants;
import org.codelibs.fess.exception.JobProcessingException;
import org.codelibs.fess.script.AbstractScriptEngine;
import org.codelibs.fess.script.ScriptEngineFactory;
import org.codelibs.fess.unit.UnitFessTestCase;
import org.codelibs.fess.util.ComponentUtil;

import java.util.concurrent.CountDownLatch;

import org.codelibs.fess.Constants;
import org.codelibs.fess.ds.callback.IndexUpdateCallback;
import org.codelibs.fess.entity.DataStoreParams;
import org.codelibs.fess.exception.JobProcessingException;
import org.codelibs.fess.opensearch.config.exentity.DataConfig;
import org.codelibs.fess.script.AbstractScriptEngine;
import org.codelibs.fess.script.ScriptEngineFactory;
import org.codelibs.fess.unit.UnitFessTestCase;

package org.codelibs.fess.job;

import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import org.codelibs.fess.Constants;
import org.codelibs.fess.exception.JobProcessingException;
import org.codelibs.fess.helper.PopularWordHelper;
import org.codelibs.fess.helper.ProcessHelper;
import org.codelibs.fess.helper.SystemHelper;
import org.codelibs.fess.mylasta.direction.FessConfig;