Skip to content

Commit 3cf0bf9

Browse files
fix astrapy bug (#141)
1 parent cece0fa commit 3cf0bf9

File tree

3 files changed

+11
-3
lines changed

3 files changed

+11
-3
lines changed

CHANGELOG.md

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,11 @@
1-
## 0.0.21-dev0
1+
## 0.0.21-dev1
22

33
### Fixes
44

55
* **Fix forward compatibility issues with `unstructured-client==0.26.0`. Update syntax and create a new SDK util file for reuse in the Partitioner and Chunker
66

7+
* **fix astra src bug**
8+
79
## 0.0.20
810

911
### Enhancements

unstructured_ingest/__version__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = "0.0.21-dev0" # pragma: no cover
1+
__version__ = "0.0.21-dev1" # pragma: no cover

unstructured_ingest/connector/astradb.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,8 +142,14 @@ def check_connection(self):
142142
@requires_dependencies(["astrapy"], extras="astradb")
143143
def get_ingest_docs(self): # type: ignore
144144
# Perform the find operation
145-
astra_db_docs = list(self.astra_db_collection.paginated_find())
145+
astra_db_docs_cursor = self.astra_db_collection.find({})
146146

147+
# Iterate over the cursor
148+
astra_db_docs = []
149+
for result in astra_db_docs_cursor:
150+
astra_db_docs.append(result)
151+
152+
# Create a list of AstraDBIngestDoc objects
147153
doc_list = []
148154
for record in astra_db_docs:
149155
doc = AstraDBIngestDoc(

0 commit comments

Comments
 (0)