Refactoring zstdnodict to zstd_no_dict (opensearch-project#340)

Signed-off-by: Sarthak Aggarwal <sarthagg@amazon.com>
tlfeng · Jun 29, 2023 · cfeceb7 · cfeceb7
1 parent d1eba71
commit cfeceb7
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/osbenchmark/workload/workload.py b/osbenchmark/workload/workload.py
@@ -718,7 +718,7 @@ class IndexCodec(Enum):
     Default = "default"
     BestCompression = "best_compression"
     ZSTD = "zstd"
-    ZSTDNODICT = "zstdnodict"
+    ZSTDNODICT = "zstd_no_dict"
 
     @classmethod
     def is_codec_valid(cls, codec):

diff --git a/tests/workload/params_test.py b/tests/workload/params_test.py
@@ -1666,7 +1666,7 @@ def test_create_index_with_zstdnodict_codec(self):
             "body": {
                 "settings": {
                     "index.number_of_replicas": 0,
-                    "index.codec": "zstdnodict"
+                    "index.codec": "zstd_no_dict"
                 },
                 "mappings": {
                     "doc": {
@@ -1686,7 +1686,7 @@ def test_create_index_with_zstdnodict_codec(self):
         self.assertEqual("test", index)
         self.assertTrue(len(body) > 0)
         self.assertEqual({}, p["request-params"])
-        self.assertEqual("zstdnodict", body["settings"]["index.codec"])
+        self.assertEqual("zstd_no_dict", body["settings"]["index.codec"])
 
     def test_create_index_with_invalid_codec(self):
         with self.assertRaises(exceptions.InvalidSyntax) as context:
@@ -1711,7 +1711,7 @@ def test_create_index_with_invalid_codec(self):
 
         self.assertEqual(str(context.exception),
                          "Please set the value properly for the create-index operation. Invalid index.codec value " +
-                         "'invalid_codec'. Choose from available codecs: ['default', 'best_compression', 'zstd', 'zstdnodict']")
+                         "'invalid_codec'. Choose from available codecs: ['default', 'best_compression', 'zstd', 'zstd_no_dict']")
 
 class CreateDataStreamParamSourceTests(TestCase):
     def test_create_data_stream(self):