writeElastisearchJsonApi(zos, id, "cluster", "pending_tasks");
        writeElastisearchJsonApi(zos, id, "nodes", "stats");
        writeElastisearchJsonApi(zos, id, "nodes", "_all");
        writeElastisearchJsonApi(zos, id, "nodes", "usage");
        writeElastisearchJsonApi(zos, id, "remote", "info");
        writeElastisearchJsonApi(zos, id, "tasks", "");

        description =
            "Command line option for the performance test task to enable profiling. " +
                "For example `async-profiler`, `async-profiler-heap`, `async-profiler-wall`, `async-profiler-all` or `jfr`. Use `none` for benchmarking only.",
    )
}

object AdHocPerformanceScenarioLinux : AdHocPerformanceScenario(Os.LINUX)

        // During rebuild, addMapping is always called with loadBulkData=false
        // because bulk data is loaded separately with createOnly=true via insertBulkData.
        for (final String[] call : testClient.addMappingCalls) {
            assertNotNull(call);
        }
        // The loadBulkData=true path triggers getResourcePath + ResourceUtil.isExist checks.

        job.setScriptType("groovy");
        job.setScriptData("println 'test'");
        job.setTarget("all");
        return job;
    }

    @FunctionalInterface
    private interface LaunchNowWithParamsCallback {
        LaunchedProcess call(LaunchNowOpCall opCall);
    }

    private void registerMockJobManager(final String jobId, final LaunchNowWithParamsCallback withParamsCallback) {

 *
 * <p>Thread Safety: This class is thread-safe. Each cached entry holds its own
 * GroovyClassLoader. The cache uses Guava Cache with segment-based locking for
 * lock-free concurrent reads. Each evaluate() call creates a new Script instance
 * to ensure thread isolation of bindings.</p>
 *
 * <p>Note on class-level isolation: Compiled Script classes are cached and reused.

{"name":"Suggest Indexer","target":"all","cronExpression":"0 12 * * *","scriptType":"groovy","scriptData":"return container.getComponent(\"suggestJob\").logLevel(\"info\").sessionId(\"SUGGEST\").execute(executor);","jobLogging":true,"crawler":false,"available":true,"sortOrder":2,"createdBy":"system","createdTime":0,"updatedBy":"system","updatedTime":0}
{"index":{"_index":"fess_config.scheduled_job","_id":"log_aggregator"}}

    /**
     * Publishes an event to all instances.
     *
     * @param eventName the event name.
     * @param data optional event data.
     */
    public void publishEvent(final String eventName, final String data) {
        publishEvent(eventName, TARGET_ALL, data);
    }

    /**
     * Publishes an event to a specific instance or all instances.
     *
     * @param eventName the event name.

        }
    }

    /**
     * For all modules providing a capability, always use the preferred module, even if there's no conflict.
     * In other words, will forcefully upgrade all modules providing a capability to a selected module.
     *
     * @param to the preferred module
     */
    private
    fun ConfigurationContainer.forceUpgrade(to: String, version: String) = all {
        resolutionStrategy.dependencySubstitution {

                    "$HIDDEN_ARTIFACT_DESTINATION/report-architecture-test-binary-compatibility-report.html",
                )
                buildReportTab("Incubating APIs Report", "incubation-reports/all-incubating.html")
            }
            if (stage.performanceTests.isNotEmpty()) {
                buildReportTab("Performance", "performance-test-results.zip!report/index.html")
            }
        }

        logger.info("Number of crawling info logs before deletion: {}", sizeBeforeDeletion);

        // Delete all old crawling sessions
        deleteMethod("/api/admin/crawlinginfo/all").then().body("response.status", equalTo(0));
        refresh();

        // Verify all old sessions are deleted (size should be 0 after deletion)
        final List<Map<String, Object>> logListAfter = readCrawlingInfo(webConfigId);