original.put("status", "running");
        original.put("createdTime", 1234567890L);

        final String json = coordinatorHelper.toJson(original);
        final Map<String, Object> parsed = coordinatorHelper.parseJson(json);

        assertEquals("operation", parsed.get("type"));
        assertEquals("reindex", parsed.get("name"));
        assertEquals("running", parsed.get("status"));

mvn clean install -DskipTests               # Then revert packaging back to war

# Integration tests (*Tests.java) - requires running Fess server
mvn test -P integrationTests -Dtest.fess.url="http://localhost:8080" -Dtest.search_engine.url="http://localhost:9201"
```

### Running
```bash
./bin/fess              # From command line
# Or run org.codelibs.fess.FessBoot from IDE

            private final Map<String, String> infoMap = new HashMap<>();

            @Override
            public void store(String sessionId, boolean running) {
                // Track the final status
                if (!running) {
                    statusMap.put(Constants.CRAWLER_STATUS, Constants.F.toString());
                }
            }

            @Override

                return "all".equals(target);
            }
        });

        int count = crawlJob.getRunningJobCount();
        assertEquals(2, count); // job1 and job3 are running
    }

    // Test getRunningJobCount with no running jobs
    @Test
    public void test_getRunningJobCount_noRunningJobs() {
        // Skip this test - requires complex DB setup
        if (true)
            return;

    /** Thread name for data store crawling process. */
    private static final String DATA_CRAWLING_PROCESS = "DataStoreCrawler";

    /** Atomic flag indicating whether the crawler is currently running. */
    private static AtomicBoolean running = new AtomicBoolean(false);

    /** Thread-safe queue for collecting error messages during crawling operations. */
    private static Queue<String> errors = new ConcurrentLinkedQueue<>();

        }

        if (!jobManager.findJobByUniqueOf(LaJobUnique.of(id)).isPresent()) {
            if (logger.isDebugEnabled()) {
                logger.debug("Job is running: id={}", id);
            }
            return;
        }

        TimeoutTask task = null;
        try {
            if (scheduledJob.isLoggingEnabled()) {
                jobHelper.store(jobLog);

        assertEquals("Test Job", jobLog.getJobName());
        assertEquals("groovy", jobLog.getScriptType());
        assertEquals("println 'hello'", jobLog.getScriptData());
        assertEquals(Constants.RUNNING, jobLog.getJobStatus());
        assertNotNull(jobLog.getStartTime());
        assertNotNull(jobLog.getLastUpdated());
        assertSame(scheduledJob, jobLog.getScheduledJob());
    }

    @Test

labels.scheduledjob_scriptType=Execution Method
labels.scheduledjob_scriptData=Script
labels.scheduledjob_jobLogging=Logging
labels.scheduledjob_crawler=Crawler Job
labels.scheduledjob_running=Running
labels.scheduledjob_active=Active
labels.scheduledjob_nojob=Disabled
labels.scheduledjob_button_start=Start Now
labels.scheduledjob_button_stop=Stop
labels.joblog_button_back=Back
labels.joblog_button_delete=Delete

 * such as Ollama, OpenAI, and Google Gemini.
 *
 * In addition to low-level chat operations, this interface defines
 * high-level RAG workflow methods that allow each provider to optimize
 * prompt construction, parameter tuning, and response parsing.
 */
public interface LlmClient {

    /**
     * Performs a chat completion request.
     *
     * @param request the chat request containing messages and parameters

        }
    }

    /**
     * Checks whether the specified operation is currently running (lock held by an active instance).
     *
     * @param operationName the operation name to check.
     * @return {@code true} if the operation is running.
     */
    public boolean isOperationRunning(final String operationName) {