RDBC-1017 Code formatter

Author: poissoncorp

ravendb/documents/operations/schema_validation/__init__.py

@@ -87,9 +87,7 @@ def __init__(self, configuration: SchemaValidationConfiguration):
     def get_command(self, conventions: DocumentConventions) -> RavenCommand:
         return self._ConfigureSchemaValidationCommand(self._configuration)
 
-    class _ConfigureSchemaValidationCommand(
-        RavenCommand[ConfigureSchemaValidationOperationResult], RaftCommand
-    ):
+    class _ConfigureSchemaValidationCommand(RavenCommand[ConfigureSchemaValidationOperationResult], RaftCommand):
         def __init__(self, configuration: SchemaValidationConfiguration):
             super().__init__(ConfigureSchemaValidationOperationResult)
             self._configuration = configuration
@@ -170,6 +168,7 @@ def from_json(cls, json_dict: Dict[str, Any]) -> "ValidateSchemaResult":
             last_etag=json_dict.get("LastEtag", 0),
         )
 
+
 class StartSchemaValidationOperation(MaintenanceOperation[OperationIdResult]):
     class Parameters:
         def __init__(
@@ -238,4 +237,3 @@ def set_response(self, response: Optional[str], from_cache: bool) -> None:
 
         def get_raft_unique_request_id(self) -> str:
             return self._raft_unique_request_id
-

ravendb/tests/operations_tests/test_schema_validation.py

@@ -48,7 +48,7 @@
 # Map that projects Schema.GetErrorsFor(doc) into an Errors field (LINQ syntax)
 _MAP_VALIDATE_DOCUMENT = (
     "from doc in docs "
-    "where MetadataFor(doc)[\"@collection\"] != \"@hilo\" "
+    'where MetadataFor(doc)["@collection"] != "@hilo" '
     "select new { Id = doc.Id, Errors = Schema.GetErrorsFor(doc) }"
 )
 
@@ -75,9 +75,7 @@ def tearDown(self):
     def test_can_configure_schema_validation(self):
         """Configure a schema for Users collection and read it back."""
         schema_def = SchemaDefinition(schema=_SCHEMA_REQUIRE_NAME)
-        config = SchemaValidationConfiguration(
-            validators_per_collection={"Users": schema_def}
-        )
+        config = SchemaValidationConfiguration(validators_per_collection={"Users": schema_def})
 
         self.store.maintenance.send(ConfigureSchemaValidationOperation(config))
 
@@ -90,9 +88,7 @@ def test_can_configure_schema_validation(self):
     def test_schema_validation_blocks_invalid_document(self):
         """Saving a document that violates the schema raises SchemaValidationException."""
         schema_def = SchemaDefinition(schema=_SCHEMA_REQUIRE_NAME)
-        config = SchemaValidationConfiguration(
-            validators_per_collection={"Users": schema_def}
-        )
+        config = SchemaValidationConfiguration(validators_per_collection={"Users": schema_def})
         self.store.maintenance.send(ConfigureSchemaValidationOperation(config))
 
         with self.assertRaises(SchemaValidationException):
@@ -105,9 +101,7 @@ def test_schema_validation_blocks_invalid_document(self):
     def test_schema_validation_allows_valid_document(self):
         """Saving a document that satisfies the schema succeeds."""
         schema_def = SchemaDefinition(schema=_SCHEMA_REQUIRE_NAME)
-        config = SchemaValidationConfiguration(
-            validators_per_collection={"Users": schema_def}
-        )
+        config = SchemaValidationConfiguration(validators_per_collection={"Users": schema_def})
         self.store.maintenance.send(ConfigureSchemaValidationOperation(config))
 
         with self.store.open_session() as session:
@@ -122,9 +116,7 @@ def test_schema_validation_allows_valid_document(self):
     def test_disabled_schema_allows_invalid_document(self):
         """When the schema is disabled, invalid documents are accepted."""
         schema_def = SchemaDefinition(schema=_SCHEMA_REQUIRE_NAME, disabled=True)
-        config = SchemaValidationConfiguration(
-            validators_per_collection={"Users": schema_def}
-        )
+        config = SchemaValidationConfiguration(validators_per_collection={"Users": schema_def})
         self.store.maintenance.send(ConfigureSchemaValidationOperation(config))
 
         with self.store.open_session() as session:
@@ -168,7 +160,7 @@ def test_start_schema_validation_operation_reports_errors(self):
         # Insert documents without a schema active so they bypass write-time validation
         with self.store.open_session() as session:
             session.store(User(name="Alice"), "users/1")
-            session.store(User(age=30), "users/2")   # missing 'name' — will fail audit
+            session.store(User(age=30), "users/2")  # missing 'name' — will fail audit
             session.save_changes()
 
         params = StartSchemaValidationOperation.Parameters(
@@ -189,7 +181,7 @@ def test_start_schema_validation_operation_with_max_error_messages(self):
         """max_error_messages caps the number of error entries returned."""
         with self.store.open_session() as session:
             for i in range(5):
-                session.store(User(age=i), f"users/{i + 1}")   # all missing 'name'
+                session.store(User(age=i), f"users/{i + 1}")  # all missing 'name'
             session.save_changes()
 
         params = StartSchemaValidationOperation.Parameters(
@@ -218,8 +210,8 @@ def test_validate_schema_start_etag_skips_earlier_docs(self):
         """
         # Schema that requires 'name' to be a string — both docs violate it (age-only)
         with self.store.open_session() as session:
-            session.store(User(age=1), "users/1")   # inserted first → lower etag
-            session.store(User(age=2), "users/2")   # inserted second → higher etag
+            session.store(User(age=1), "users/1")  # inserted first → lower etag
+            session.store(User(age=2), "users/2")  # inserted second → higher etag
             session.save_changes()
 
         params1 = StartSchemaValidationOperation.Parameters(
@@ -274,7 +266,6 @@ def test_validate_schema_max_documents_to_validate_caps_scan(self):
         self.assertGreater(result.last_etag, 0)
 
 
-
 # ---------------------------------------------------------------------------
 # Helper result class for indexing tests
 # ---------------------------------------------------------------------------