Add --async_replication_config reset and use replace semantics

Support "reset" keyword to revert all async replication settings to
server defaults. Use `is not None` checks so empty dict (reset) is
correctly forwarded as an empty async_config() call. Update version
references to v1.34.18.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: jfrancoa

test/unittests/test_utils.py

@@ -445,3 +445,19 @@ def test_parse_async_replication_config_invalid_value():
 def test_parse_async_replication_config_missing_equals():
     with pytest.raises(ValueError, match="Expected key=value"):
         parse_async_replication_config(("max_workers",))
+
+
+def test_parse_async_replication_config_reset():
+    result = parse_async_replication_config(("reset",))
+    assert result == {}
+
+
+def test_parse_async_replication_config_reset_case_insensitive():
+    assert parse_async_replication_config(("Reset",)) == {}
+    assert parse_async_replication_config(("RESET",)) == {}
+    assert parse_async_replication_config((" reset ",)) == {}
+
+
+def test_parse_async_replication_config_reset_with_other_keys():
+    with pytest.raises(ValueError, match="Expected key=value"):
+        parse_async_replication_config(("reset", "max_workers=10"))

weaviate_cli/managers/collection_manager.py

@@ -244,12 +244,14 @@ def create_collection(
                 f"Error: Collection '{collection}' already exists in Weaviate. Delete using <delete collection> command."
             )
 
-        if async_replication_config and not async_enabled:
+        if async_replication_config is not None and not async_enabled:
             raise Exception(
                 "Error: --async_replication_config requires --async_enabled to be set."
             )
 
-        if async_replication_config and older_than_version(self.client, "1.34.18"):
+        if async_replication_config is not None and older_than_version(
+            self.client, "1.34.18"
+        ):
             click.echo(
                 "Warning: --async_replication_config requires Weaviate >= v1.34.18. "
                 "The server may ignore or reject these settings."
@@ -570,7 +572,7 @@ def create_collection(
                         wvc.Configure.Replication.async_config(
                             **async_replication_config
                         )
-                        if async_replication_config
+                        if async_replication_config is not None
                         else None
                     ),
                 ),
@@ -650,12 +652,14 @@ def update_collection(
             raise Exception(
                 "object_ttl_property_name is only valid when object_ttl_type is 'property'."
             )
-        if async_replication_config and async_enabled is False:
+        if async_replication_config is not None and async_enabled is False:
             raise Exception(
                 "Error: --async_replication_config cannot be used when --async_enabled is False."
             )
 
-        if async_replication_config and older_than_version(self.client, "1.34.18"):
+        if async_replication_config is not None and older_than_version(
+            self.client, "1.34.18"
+        ):
             click.echo(
                 "Warning: --async_replication_config requires Weaviate >= v1.34.18. "
                 "The server may ignore or reject these settings."
@@ -750,7 +754,7 @@ def update_collection(
                         wvc.Reconfigure.Replication.async_config(
                             **async_replication_config
                         )
-                        if async_replication_config
+                        if async_replication_config is not None
                         else None
                     ),
                 )

weaviate_cli/utils.py

@@ -134,6 +134,8 @@ def pp_objects(response, main_properties, json_output: bool = False):
 }
 
 
+ASYNC_REPLICATION_CONFIG_RESET = "reset"
+
 ASYNC_REPLICATION_CONFIG_HELP = (
     "Async replication config as key=value pairs. Can be specified multiple times. "
     "Valid keys: " + ", ".join(sorted(ASYNC_REPLICATION_CONFIG_KEYS)) + ". "
@@ -149,17 +151,22 @@ def parse_async_replication_config(
     """Parse async replication config key=value tuples into a dict.
 
     Args:
-        config_tuples: Tuple of "key=value" strings, e.g. ("max_workers=10", "frequency=60")
+        config_tuples: Tuple of "key=value" strings, e.g. ("max_workers=10", "frequency=60"),
+            or a single "reset" to revert all settings to server defaults.
 
     Returns:
-        Dict mapping parameter names to integer values, or None if empty/None.
+        Dict mapping parameter names to integer values, empty dict for "reset",
+        or None if empty/None.
 
     Raises:
         ValueError: If a key is unknown or a value is not a valid integer.
     """
     if not config_tuples:
         return None
 
+    if len(config_tuples) == 1 and config_tuples[0].strip().lower() == "reset":
+        return {}
+
     result = {}
     for item in config_tuples:
         if "=" not in item: