Merge pull request #173 from IlyaSkriblovsky/bulk-ops

Fixed handling of connection errors in bulk_write
twisted · Jun 23, 2016 · 49cd126 · 49cd126
2 parents 202ed5a + 658e0cc
commit 49cd126
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/txmongo/collection.py b/txmongo/collection.py
@@ -1171,6 +1171,9 @@ def accumulate_result(reply, idx_offset):
                     all_responses.append(batch_result)
 
         if self.write_concern.acknowledged and not ordered:
-            yield defer.DeferredList(all_responses)
+            try:
+                yield defer.gatherResults(all_responses, consumeErrors=True)
+            except defer.FirstError as e:
+                e.subFailure.raiseException()
 
         defer.returnValue(results)