Compare bulk.execute()['writeErrors'] to expected value. Like: {'index': 0, 'code': 123, 'errmsg': '...', 'op': { ... }}
(self, expected, actual)
| 99 | self.assertEqual(expected["_id"], actual["_id"]) |
| 100 | |
| 101 | def assertEqualWriteError(self, expected, actual): |
| 102 | """Compare bulk.execute()['writeErrors'] to expected value. |
| 103 | |
| 104 | Like: {'index': 0, 'code': 123, 'errmsg': '...', 'op': { ... }} |
| 105 | """ |
| 106 | self.assertEqual(expected["index"], actual["index"]) |
| 107 | self.assertEqual(expected["code"], actual["code"]) |
| 108 | if expected["errmsg"] == "...": |
| 109 | # Unspecified value. |
| 110 | self.assertIn("errmsg", actual) |
| 111 | else: |
| 112 | self.assertEqual(expected["errmsg"], actual["errmsg"]) |
| 113 | |
| 114 | expected_op = expected["op"].copy() |
| 115 | actual_op = actual["op"].copy() |
| 116 | if expected_op.get("_id") == "...": |
| 117 | # Unspecified _id. |
| 118 | self.assertIn("_id", actual_op) |
| 119 | actual_op.pop("_id") |
| 120 | expected_op.pop("_id") |
| 121 | |
| 122 | self.assertEqual(expected_op, actual_op) |
| 123 | |
| 124 | |
| 125 | class TestBulk(BulkTestBase): |
no test coverage detected