diff --git a/twistes/bulk_utils.py b/twistes/bulk_utils.py index d0dd462..7ec3a47 100644 --- a/twistes/bulk_utils.py +++ b/twistes/bulk_utils.py @@ -73,16 +73,17 @@ def bulk(self, actions, stats_only=False, verbose=False, **kwargs): inserted = [] errors = [] - + all = [] for deferred_bulk in self.streaming_bulk(actions, **kwargs): bulk_results = yield deferred_bulk for ok, item in bulk_results: # go through request-response pairs and detect failures + all.append((ok, item)) l = inserted if ok else errors l.append(item) if verbose: - returnValue((inserted, errors)) + returnValue(all) if stats_only: returnValue((len(inserted), len(errors)))