assertTrue(executor.awaitTermination(30, TimeUnit.SECONDS), "All threads should complete within timeout");

            // Analyze timing consistency across threads
            if (!timings.isEmpty()) {
                double avgTime = timings.stream().mapToLong(Long::longValue).average().orElse(0.0);
                long maxTime = timings.stream().mapToLong(Long::longValue).max().orElse(0L);

        } else {
            project.afterEvaluate(spec -> {
                if (extension.fixtures.isEmpty()) {
                    // if only one fixture is used, that's this one, but without a compose file that's not a valid configuration
                    throw new IllegalStateException(

        json.append("\"severity\":\"").append(entry.severity.name()).append("\",");
        json.append("\"message\":\"").append(escapeJson(entry.message)).append("\"");

        if (!entry.context.isEmpty()) {
            json.append(",\"context\":{");
            boolean first = true;
            for (Map.Entry<String, Object> e : entry.context.entrySet()) {
                if (e.getValue() != null) {

                }

                Set<Artifact> directArtifacts = resolutionGroup.getArtifacts();

                if (artifacts == null || artifacts.isEmpty()) {
                    artifacts = directArtifacts;
                } else {
                    List<Artifact> allArtifacts = new ArrayList<>();
                    allArtifacts.addAll(artifacts);

     * @throws SearchEngineClientException if the bulk indexing operation fails
     */
    public void sendDocuments(final SearchEngineClient searchEngineClient, final DocList docList) {
        if (docList.isEmpty()) {
            return;
        }
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        final SystemHelper systemHelper = ComponentUtil.getSystemHelper();

                // Pre-order: horizon.addFirst(successors)
                order.insertInto(horizon, successors);
              }
              return next;
            }
          } while (!horizon.isEmpty());
          return endOfData();
        }
      };
    }

    final Iterator<N> postOrder(Iterator<? extends N> startNodes) {
      Deque<N> ancestorStack = new ArrayDeque<>();

     * @param paramMap The parameters.
     * @return The converted value.
     */
    protected Object convertValue(final String scriptType, final String template, final Map<String, Object> paramMap) {
        if (StringUtil.isEmpty(template)) {
            return StringUtil.EMPTY;
        }

        if (paramMap.containsKey(template)) {
            return paramMap.get(template);
        }

        public ChatSource(final int index, final Map<String, Object> doc) {
            this.index = index;
            String titleValue = toStringOrNull(doc.get("title"));
            if (titleValue == null || titleValue.isEmpty()) {
                titleValue = toStringOrNull(doc.get("content_title"));
            }
            this.title = titleValue;
            this.url = toStringOrNull(doc.get("url"));

    /**
     * Checks if any sort builders have been added to this context.
     * @return True if sort builders are present, false otherwise.
     */
    public boolean hasSorts() {
        return !sortBuilderList.isEmpty();
    }

    /**
     * Gets the list of sort builders for this query context.
     * @return The list of sort builders.
     */
    public List<SortBuilder<?>> sortBuilders() {

        final ListResultBean<DataConfig> list = dataConfigBhv.selectList(cb -> {
            cb.query().setName_Equal(name);
            cb.query().addOrderBy_SortOrder_Asc();
        });
        if (list.isEmpty()) {
            return OptionalEntity.empty();
        }
        return OptionalEntity.of(list.get(0));
    }

    /**
     * Stores (inserts or updates) a data configuration.
     *