Add a document to the batch query
(
self,
doc_id,
nosave=False,
score=1.0,
payload=None,
replace=False,
partial=False,
no_create=False,
**fields,
)
| 38 | self.commit() |
| 39 | |
| 40 | def add_document( |
| 41 | self, |
| 42 | doc_id, |
| 43 | nosave=False, |
| 44 | score=1.0, |
| 45 | payload=None, |
| 46 | replace=False, |
| 47 | partial=False, |
| 48 | no_create=False, |
| 49 | **fields, |
| 50 | ): |
| 51 | """ |
| 52 | Add a document to the batch query |
| 53 | """ |
| 54 | self.client._add_document( |
| 55 | doc_id, |
| 56 | conn=self._pipeline, |
| 57 | nosave=nosave, |
| 58 | score=score, |
| 59 | payload=payload, |
| 60 | replace=replace, |
| 61 | partial=partial, |
| 62 | no_create=no_create, |
| 63 | **fields, |
| 64 | ) |
| 65 | self.current_chunk += 1 |
| 66 | self.total += 1 |
| 67 | if self.current_chunk >= self.chunk_size: |
| 68 | self.commit() |
| 69 | |
| 70 | def add_document_hash(self, doc_id, score=1.0, replace=False): |
| 71 | """ |
nothing calls this directly
no test coverage detected