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,
)
| 121 | """ |
| 122 | |
| 123 | async def add_document( |
| 124 | self, |
| 125 | doc_id, |
| 126 | nosave=False, |
| 127 | score=1.0, |
| 128 | payload=None, |
| 129 | replace=False, |
| 130 | partial=False, |
| 131 | no_create=False, |
| 132 | **fields, |
| 133 | ): |
| 134 | """ |
| 135 | Add a document to the batch query |
| 136 | """ |
| 137 | self.client._add_document( |
| 138 | doc_id, |
| 139 | conn=self._pipeline, |
| 140 | nosave=nosave, |
| 141 | score=score, |
| 142 | payload=payload, |
| 143 | replace=replace, |
| 144 | partial=partial, |
| 145 | no_create=no_create, |
| 146 | **fields, |
| 147 | ) |
| 148 | self.current_chunk += 1 |
| 149 | self.total += 1 |
| 150 | if self.current_chunk >= self.chunk_size: |
| 151 | await self.commit() |
| 152 | |
| 153 | async def commit(self): |
| 154 | """ |
nothing calls this directly
no test coverage detected