From 21063c57285ef44e6172ce65cb7917a57750426e Mon Sep 17 00:00:00 2001 From: Oded Lazar Date: Thu, 6 Apr 2017 17:57:55 +0300 Subject: [PATCH] Change behavior of 'all' flag in bulk insert --- twistes/bulk_utils.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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)))