}

    // Test getExecuteType
    @Test
    public void test_getExecuteType() {
        assertEquals("test", execJob.getExecuteType());

        execJob.setExecuteType("crawler");
        assertEquals("crawler", execJob.getExecuteType());
    }

    // Test jobExecutor setter
    @Test
    public void test_jobExecutor() {
        JobExecutor jobExecutor = new JobExecutor() {

     *
     * @param jobExecutor the job executor to use for execution
     * @return the execution result message or summary
     */
    public String execute(final JobExecutor jobExecutor) {
        jobExecutor(jobExecutor);
        return execute();
    }

    /**
     * Sets the job executor for this job.
     *
     * @param jobExecutor the job executor to set

        ComponentUtil.register(jobHelper, "jobHelper");

        // JobExecutor that returns a simple result
        final JobExecutor jobExecutor = new JobExecutor() {
            @Override
            public Object execute(final String scriptType, final String script) {
                return "OK";
            }
        };
        ComponentUtil.register(jobExecutor, "scriptJobExecutor");
    }

    /**

                + ".webConfigIds([\"%s\"] as String[])" + ".jobExecutor(executor).execute();", webCofigId, webCofigId);
    }

    protected static String buildFileConfigJobScript(final String fileConfigId) {
        return String.format("return container.getComponent(\"crawlJob\")" + ".logLevel(\"info\")" + ".sessionId(\"%s\")"
                + ".fileConfigIds([\"%s\"] as String[])" + ".jobExecutor(executor).execute();", fileConfigId, fileConfigId);
    }

    public void test_execute_withJobExecutor() {
        pythonJob.filename("test.py");

        TestJobExecutor jobExecutor = new TestJobExecutor();
        pythonJob.jobExecutor = jobExecutor;

        testProcessHelper.exitValue = 0;

        pythonJob.execute();

        assertTrue(jobExecutor.shutdownListenerAdded);
    }

    // Test environment variables setup
    @Test

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

    // Test with jobExecutor set
    @Test
    public void test_execute_withJobExecutor() {
        final List<JobExecutor.ShutdownListener> shutdownListeners = new ArrayList<>();

        JobExecutor mockJobExecutor = new JobExecutor() {
            @Override
            public void addShutdownListener(ShutdownListener listener) {

            sessionId = RandomStringUtils.randomAlphabetic(15);
        }
        resultBuf.append("Session Id: ").append(sessionId).append("\n");
        if (jobExecutor != null) {
            jobExecutor.addShutdownListener(() -> ComponentUtil.getProcessHelper().destroyProcess(sessionId));
        }

        final TimeoutTask timeoutTask = createTimeoutTask();
        try {

            sessionId = RandomStringUtils.randomAlphabetic(15);
        }
        resultBuf.append("Session Id: ").append(sessionId).append("\n");
        if (jobExecutor != null) {
            jobExecutor.addShutdownListener(() -> ComponentUtil.getProcessHelper().destroyProcess(sessionId));
        }

        final TimeoutTask timeoutTask = createTimeoutTask();
        try {

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.job.impl;

import java.util.Map;

import org.codelibs.fess.exception.ScriptEngineException;
import org.codelibs.fess.job.JobExecutor;
import org.codelibs.fess.script.ScriptEngine;
import org.codelibs.fess.script.ScriptEngineFactory;
import org.codelibs.fess.unit.UnitFessTestCase;
import org.codelibs.fess.util.ComponentUtil;

            cacheCleared = true;
        }

        public boolean isCacheCleared() {
            return cacheCleared;
        }
    }

    // Mock JobExecutor implementation
    private class MockJobExecutor extends JobExecutor {
        private boolean hasShutdownListener = false;

        @Override
        public void addShutdownListener(ShutdownListener listener) {