(self)
| 194 | self._consistency = consistency |
| 195 | |
| 196 | def _execute_callbacks(self): |
| 197 | for callback, args, kwargs in self._callbacks: |
| 198 | callback(*args, **kwargs) |
| 199 | |
| 200 | def add_callback(self, fn, *args, **kwargs): |
| 201 | """Add a function and arguments to be passed to it to be executed after the batch executes. |