Skip to content

Commit f8a5978

Browse files
committed
fix(weaviate): restore comments and remove duplicate async test
1 parent 162da68 commit f8a5978

2 files changed

Lines changed: 1 addition & 14 deletions

File tree

integrations/weaviate/src/haystack_integrations/document_stores/weaviate/document_store.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1363,7 +1363,7 @@ def update_by_filter(self, filters: dict[str, Any], meta: dict[str, Any]) -> int
13631363
matching_objects = self._query_with_filters(filters)
13641364
if not matching_objects:
13651365
return 0
1366-
1366+
13671367
# Update each object with the new metadata
13681368
# Since metadata is stored flattened in Weaviate properties, we update properties directly
13691369
updated_count = 0

integrations/weaviate/tests/test_document_store_async.py

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -186,19 +186,6 @@ async def test_filter_documents_over_default_limit(self, document_store: Weaviat
186186
{"field": "content", "operator": "==", "value": "This is some content"}
187187
)
188188

189-
@pytest.mark.asyncio
190-
async def test_write_documents_async(self, document_store: WeaviateDocumentStore) -> None:
191-
"""
192-
Test write_documents() with default policy overwrites existing documents.
193-
"""
194-
doc = Document(content="test doc")
195-
assert await document_store.write_documents_async([doc]) == 1
196-
assert await document_store.count_documents_async() == 1
197-
198-
doc.content = "test doc 2"
199-
assert await document_store.write_documents_async([doc]) == 1
200-
assert await document_store.count_documents_async() == 1
201-
202189
@pytest.mark.asyncio
203190
async def test_write_documents_with_tenant_async(self, document_store):
204191
doc = Document(content="tenant test doc")

0 commit comments

Comments
 (0)