esclean: fix retry

Signed-off-by: Jakub Sokołowski <jakub@status.im>
2020-02-19 23:01:36 +01:00 · 2020-02-19 23:01:36 +01:00 · a647b307e9
parent e0194ef67c
commit a647b307e9
1 changed files with 1 additions and 1 deletions
--- a/elasticsearch/esclean.py
+++ b/elasticsearch/esclean.py
@ -41,7 +41,7 @@ def print_logs(docs):
            log['logsource'], log['message'][:90]
        ))

-retry(ConflictError, tries=3, delay=6000, backoff=6000)
+@retry(ConflictError, tries=3, delay=6000, backoff=6000)
 def delete_retry(es, index, body):
    return es.delete_by_query(index=index, body=body)