If elasticsearch persistence is enabled, also persist opensearch

GREsau · Nov 9, 2023 · 9ae45d8 · 9ae45d8
1 parent cf681e4
commit 9ae45d8
Showing 1 changed file with 11 additions and 4 deletions.
diff --git a/src/localstack_persist/config.py b/src/localstack_persist/config.py
@@ -9,7 +9,7 @@
 
 
 def normalise_service_name(n: str):
-    return (
+    service_name = (
         n.strip()
         .lower()
         .replace(
@@ -21,6 +21,9 @@ def normalise_service_name(n: str):
             "",
         )
     )
+    if service_name == "elasticsearch":
+        return "es"
+    return service_name
 
 
 PERSISTED_SERVICES = {"default": True}
@@ -42,6 +45,10 @@ def normalise_service_name(n: str):
 
 
 def is_persistence_enabled(service_name: str):
-    return PERSISTED_SERVICES.get(
-        normalise_service_name(service_name), PERSISTED_SERVICES["default"]
-    )
+    service_name = normalise_service_name(service_name)
+
+    # elasticsearch requires opensearch
+    if service_name == "opensearch" and is_persistence_enabled("es"):
+        return True
+
+    return PERSISTED_SERVICES.get(service_name, PERSISTED_SERVICES["default"])