diff --git a/src/python/WMCore/WorkQueue/WorkQueueBackend.py b/src/python/WMCore/WorkQueue/WorkQueueBackend.py index 08fc02739f..d9d0ec6db5 100644 --- a/src/python/WMCore/WorkQueue/WorkQueueBackend.py +++ b/src/python/WMCore/WorkQueue/WorkQueueBackend.py @@ -174,7 +174,7 @@ def insertElements(self, units, parent=None): else: newUnitsInserted.append(unit) unit.save() - unit._couch.commit(all_or_nothing=True) + unit._couch.commit() return newUnitsInserted diff --git a/test/python/WMCore_t/Database_t/CMSCouch_t.py b/test/python/WMCore_t/Database_t/CMSCouch_t.py index 6d705ebf88..4622e33358 100644 --- a/test/python/WMCore_t/Database_t/CMSCouch_t.py +++ b/test/python/WMCore_t/Database_t/CMSCouch_t.py @@ -283,10 +283,9 @@ def testCommit(self): self.assertEqual(answer[0]['ok'], True) self.assertEqual(answer[1]['error'], 'conflict') - # all_or_nothing mode ignores conflicts self.db.queue(Document(id = "2", inputDict = doc)) self.db.queue(Document(id = "2", inputDict = {'foo':1234, 'bar':456})) - answer = self.db.commit(all_or_nothing = True) + answer = self.db.commit() self.assertEqual(2, len(answer)) self.assertEqual(answer[0].get('error'), None) self.assertEqual(answer[0].get('error'), None)