@Test
    public void test_completeOperation_ownInstance_deletesDoc() {
        setupMockFessConfig();
        final String getResponse = "{\"found\":true,\"_seq_no\":5,\"_primary_term\":1,"
                + "\"_source\":{\"type\":\"operation\",\"name\":\"reindex\"," + "\"instanceId\":\"node1@host1\",\"status\":\"running\"}}";

                builder.addKind(SuggestItem.Kind.DOCUMENT.toString());
            }

            final SuggestResponse suggestResponse = builder.execute().getResponse();

            buf.append("\"query_time\":").append(suggestResponse.getTookMs());
            buf.append(",\"record_count\":").append(suggestResponse.getTotal());

     */
    public void completeOperation(final String operationName) {
        try (CurlResponse getResponse = ComponentUtil.getCurlHelper() //
                .get("/" + getIndexName() + "/_doc/" + operationName) //
                .execute()) {
            if (getResponse.getHttpStatusCode() != 200) {
                logger.debug("Operation document not found: operation={}", operationName);

            final SearchResult<T, GetRequestBuilder, GetResponse> searchResult) {
        final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
        final long startTime = systemHelper.getCurrentTimeAsLong();

        GetResponse response = null;
        final GetRequestBuilder requestBuilder = client.prepareGet(index, id);