fix for snafu/ripsaw index

changed snafu to use the provided env index prefix fixed typo in py_es_bulk for retry logic
cloud-bulldozer · Sep 11, 2019 · 330e92b · 330e92b
1 parent 6ec5c2b
commit 330e92b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/run_snafu.py b/run_snafu.py
@@ -54,7 +54,7 @@ def main():
     if "es" in os.environ:
         es['server'] = os.environ["es"]
         es['port'] = os.environ["es_port"]
-        index_args.prefix = "%s-%s" % (os.environ["es_index"], index_args.tool)
+        index_args.prefix = os.environ["es_index"]
         index_args.index_results = True
 
         es = elasticsearch.Elasticsearch([

diff --git a/utils/py_es_bulk.py b/utils/py_es_bulk.py
@@ -123,7 +123,7 @@ def actions_tracking_closure(cl_actions):
             # start yielding those actions until we drain the retry queue.
             backoff = 1
             while len(actions_retry_deque) > 0:
-                time.sleep(calc_backoff_sleep(backoff))
+                time.sleep(_calc_backoff_sleep(backoff))
                 retries_tracker['retries'] += 1
                 retry_actions = []
                 # First drain the retry deque entirely so that we know when we