From 3de894b01df8109084ac384da4d339b5aeac5408 Mon Sep 17 00:00:00 2001 From: Anoop Panicker Date: Thu, 14 Feb 2019 11:09:40 -0800 Subject: [PATCH] added TIMED_OUT and TERMINATED workflows to archivable --- .../com/netflix/conductor/dao/es/index/ElasticSearchDAO.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/es2-persistence/src/main/java/com/netflix/conductor/dao/es/index/ElasticSearchDAO.java b/es2-persistence/src/main/java/com/netflix/conductor/dao/es/index/ElasticSearchDAO.java index c37df2ad7a..7aa2c97a1b 100644 --- a/es2-persistence/src/main/java/com/netflix/conductor/dao/es/index/ElasticSearchDAO.java +++ b/es2-persistence/src/main/java/com/netflix/conductor/dao/es/index/ElasticSearchDAO.java @@ -500,6 +500,8 @@ public List searchArchivableWorkflows(String indexName, long archiveTtlD QueryBuilder q = QueryBuilders.boolQuery() .should(QueryBuilders.termQuery("status", "COMPLETED")) .should(QueryBuilders.termQuery("status", "FAILED")) + .should(QueryBuilders.termQuery("status", "TIMED_OUT")) + .should(QueryBuilders.termQuery("status", "TERMINATED")) .mustNot(QueryBuilders.existsQuery("archived")) .minimumNumberShouldMatch(1); SearchRequestBuilder s = elasticSearchClient.prepareSearch(indexName)