final List<Map<String, Object>> resList = new ArrayList<>();
        for (Map<String, Object> elem : logList) {
            logger.info("config_id: {}, session_id: {}", configId, elem.get("session_id"));
            if (elem.containsKey("session_id") && elem.get("session_id").equals(configId.replace('-', '_'))) {
                resList.add(elem);
            }
        }
        return resList;
    }

     *
     * @param sessionId The session ID.
     * @param url The URL to add.
     */
    @Override
    public void add(final String sessionId, final String url) {
        if (exists(sessionId, url)) {
            return;
        }
        final OpenSearchUrlQueue urlQueue = new OpenSearchUrlQueue();
        urlQueue.setSessionId(sessionId);
        urlQueue.setUrl(url);

    /**
     * Gets the count of access results for a specific session.
     *
     * @param sessionId The session ID.
     * @return The number of access results for the session.
     */
    @Override
    public int getCount(final String sessionId) {
        return getCount(builder -> builder.setQuery(QueryBuilders.termQuery(SESSION_ID, sessionId)));
    }

    /**
     * Deletes all access results for a specific session.
     *

                } else {
                    final BoolQueryBuilder boolQuery = QueryBuilders.boolQuery().filter(QueryBuilders.termQuery(SESSION_ID, sessionId));
                    if (queryBuilder != null) {
                        boolQuery.must(queryBuilder);
                    }
                    builder.setQuery(boolQuery);
                }
            } else if (queryBuilder != null) {

        // Test with session ID filter
        if (!logList.isEmpty()) {
            final String sessionId = (String) logList.get(0).get("session_id");
            final Map<String, Object> filterBody = new HashMap<>();
            filterBody.put("session_id", sessionId);
            response = checkMethodBase(filterBody).get("/api/admin/crawlinginfo/logs").asString();

        String result = pythonJob.execute();

        assertNotNull(result);
        assertTrue(result.contains("Session Id:"));
        assertNotNull(pythonJob.sessionId);
        assertTrue(pythonJob.sessionId.length() >= 10);

        // The test doesn't actually call the real process since ServletContext.getRealPath returns null in test
        // and causes an exception which is caught and added to result

    /** Info map key for data index size. */
    public static final String DATA_INDEX_SIZE = "DataIndexSize";

    /** Session identifier key. */
    public static final String SESSION_ID = "sessionId";

    /** Crawling information identifier key. */
    public static final String CRAWLING_INFO_ID = "crawlingInfoId";

    /** Indexing target identifier key. */

                return;
            }
            final String sessionId = initParamMap.getAsString(Constants.SESSION_ID);
            if (StringUtil.isBlank(sessionId)) {
                logger.warn("[{}] Cannot delete stale documents: sessionId is not set.", dataConfig.getName());
                return;
            }

            }
            responseData.setExecutionTime(systemHelper.getCurrentTimeAsLong() - startTime);
            if (dataMap.containsKey(Constants.SESSION_ID)) {
                responseData.setSessionId((String) dataMap.get(Constants.SESSION_ID));
            } else {
                responseData.setSessionId((String) paramMap.get(Constants.CRAWLING_INFO_ID));
            }

     *
     * @param sessionId the session ID whose data should be deleted
     */
    private void deleteBySessionId(final String sessionId) {
        try {
            urlFilterService.delete(sessionId);
        } catch (final Exception e) {
            logger.warn("Failed to delete UrlFilter: sessionId={}", sessionId, e);
        }
        try {