From 3710e09c3f6021684b5995cab549ce58e81d4bf4 Mon Sep 17 00:00:00 2001 From: Kishore Date: Fri, 13 Jul 2018 19:10:36 -0700 Subject: [PATCH] Fixed searchArchivableWorkflows rangeQuery. --- .../com/netflix/conductor/dao/es5/index/ElasticSearchDAOV5.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/es5-persistence/src/main/java/com/netflix/conductor/dao/es5/index/ElasticSearchDAOV5.java b/es5-persistence/src/main/java/com/netflix/conductor/dao/es5/index/ElasticSearchDAOV5.java index ab84298afb..0cb44fb186 100644 --- a/es5-persistence/src/main/java/com/netflix/conductor/dao/es5/index/ElasticSearchDAOV5.java +++ b/es5-persistence/src/main/java/com/netflix/conductor/dao/es5/index/ElasticSearchDAOV5.java @@ -493,7 +493,7 @@ private SearchResult search(String structuredQuery, int start, int size, @Override public List searchArchivableWorkflows(String indexName, long archiveTtlDays) { QueryBuilder q = QueryBuilders.boolQuery() - .must(QueryBuilders.rangeQuery("endTime").lt(LocalDate.now().minusDays(archiveTtlDays))) + .must(QueryBuilders.rangeQuery("endTime").lt(LocalDate.now().minusDays(archiveTtlDays).toString())) .should(QueryBuilders.termQuery("status", "COMPLETED")) .should(QueryBuilders.termQuery("status", "FAILED")) .mustNot(QueryBuilders.existsQuery("archived"))