(self)
Called by the BulkDocProcessorEventHandler
Called by the BulkDocProcessorEventHandler
Called by the BulkDocProcessorEventHandler
def process_chunk(self):
        """Called by the BulkDocProcessorEventHandler"""
        ok = self.doc_processor.process_bulk_docs(self.changes, self.progress.logger)
        if ok:
            self.progress.add(len(self.changes))
            self.changes = []
        else:
            raise BulkProcessingFailed("Processing batch failed")
def process_chunk ( self ) : ok = self . doc_processor . process_bulk_docs ( self . changes , self . progress . logger ) if ok : self . progress . add ( len ( self . changes ) ) self . changes = [ ] else : raise BulkProcessingFailed ( "Processing batch failed" )