move constant to env ELASTICSEARCH_POST_INDEX_DELAY

aaxelb · aaxelb · commit 088065079826 · 2024-12-05T12:46:36.000-05:00
diff --git a/project/settings.py b/project/settings.py
@@ -314,6 +314,7 @@ def split(string, delim):
     'TIMEOUT': int(os.environ.get('ELASTICSEARCH_TIMEOUT', '45')),
     'CHUNK_SIZE': int(os.environ.get('ELASTICSEARCH_CHUNK_SIZE', 2000)),
     'MAX_RETRIES': int(os.environ.get('ELASTICSEARCH_MAX_RETRIES', 7)),
+    'POST_INDEX_DELAY': int(os.environ.get('ELASTICSEARCH_POST_INDEX_DELAY', 3)),
 }
 ELASTICSEARCH5_URL = (
     os.environ.get('ELASTICSEARCH5_URL')
diff --git a/share/search/index_strategy/trovesearch_denorm.py b/share/search/index_strategy/trovesearch_denorm.py
@@ -162,7 +162,7 @@ def after_chunk(self, messages_chunk: messages.MessagesChunk, indexnames: Iterab
                 'card_pks': messages_chunk.target_ids_chunk,
                 'timestamp': messages_chunk.timestamp,
             },
-            countdown=3,  # TODO: config?
+            countdown=settings.ELASTICSEARCH['POST_INDEX_DELAY'],
         )
 
     # abstract method from Elastic8IndexStrategy

Original file line number	Diff line number	Diff line change
`@@ -314,6 +314,7 @@ def split(string, delim):`
`314`	`314`	`'TIMEOUT': int(os.environ.get('ELASTICSEARCH_TIMEOUT', '45')),`
`315`	`315`	`'CHUNK_SIZE': int(os.environ.get('ELASTICSEARCH_CHUNK_SIZE', 2000)),`
`316`	`316`	`'MAX_RETRIES': int(os.environ.get('ELASTICSEARCH_MAX_RETRIES', 7)),`
	`317`	`+ 'POST_INDEX_DELAY': int(os.environ.get('ELASTICSEARCH_POST_INDEX_DELAY', 3)),`
`317`	`318`	`}`
`318`	`319`	`ELASTICSEARCH5_URL = (`
`319`	`320`	`os.environ.get('ELASTICSEARCH5_URL')`
Original file line number	Diff line number	Diff line change
`@@ -162,7 +162,7 @@ def after_chunk(self, messages_chunk: messages.MessagesChunk, indexnames: Iterab`
`162`	`162`	`'card_pks': messages_chunk.target_ids_chunk,`
`163`	`163`	`'timestamp': messages_chunk.timestamp,`
`164`	`164`	`},`
`165`		`- countdown=3, # TODO: config?`
	`165`	`+ countdown=settings.ELASTICSEARCH['POST_INDEX_DELAY'],`
`166`	`166`	`)`
`167`	`167`
`168`	`168`	`# abstract method from Elastic8IndexStrategy`