Skip to content

Commit 4e2cd24

Browse files
test(weaviate): override test_write_documents_async required by mixin
WriteDocumentsAsyncTest.test_write_documents_async raises NotImplementedError by design — each store must define its own default-policy behaviour. Weaviate's default overwrites existing documents, same as the sync test.
1 parent 19bc037 commit 4e2cd24

1 file changed

Lines changed: 11 additions & 0 deletions

File tree

integrations/weaviate/tests/test_document_store_async.py

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -126,6 +126,17 @@ def assert_documents_are_equal(self, received: list[Document], expected: list[Do
126126
for key in meta_keys:
127127
assert received_meta.get(key) == expected_meta.get(key)
128128

129+
async def test_write_documents_async(self, document_store: WeaviateDocumentStore) -> None:
130+
# Override: mixin raises NotImplementedError and requires each store to define its own
131+
# default-policy behaviour. Weaviate's default overwrites existing documents.
132+
doc = Document(content="test doc")
133+
assert await document_store.write_documents_async([doc]) == 1
134+
assert await document_store.count_documents_async() == 1
135+
136+
doc = dataclasses.replace(doc, content="test doc 2")
137+
assert await document_store.write_documents_async([doc]) == 1
138+
assert await document_store.count_documents_async() == 1
139+
129140
async def test_count_not_empty_async(self, document_store: WeaviateDocumentStore) -> None:
130141
# Override: the mixin defines this without `self`, which breaks under asyncio_mode=auto.
131142
# Body is identical to the mixin's version.

0 commit comments

Comments
 (0)