Skip to content

Commit 94ca2f8

Browse files
committed
review changes
1 parent afbde7f commit 94ca2f8

File tree

2 files changed

+3
-9
lines changed

2 files changed

+3
-9
lines changed

pymongo/helpers.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ def _check_command_response(response, max_wire_version,
116116

117117
if parse_write_concern_error and 'writeConcernError' in response:
118118
_error = response["writeConcernError"]
119-
_labels = response.get("errorLabels", [])
119+
_labels = response.get("errorLabels")
120120
if _labels:
121121
_error.update({'errorLabels': _labels})
122122
_raise_write_concern_error(_error)
@@ -225,9 +225,9 @@ def _check_write_command_response(result):
225225
if write_errors:
226226
_raise_last_write_error(write_errors)
227227

228-
error = result.get("writeConcernError", {})
228+
error = result.get("writeConcernError")
229229
if error:
230-
error_labels = result.get("errorLabels", [])
230+
error_labels = result.get("errorLabels")
231231
if error_labels:
232232
error.update({'errorLabels': error_labels})
233233
_raise_write_concern_error(error)

test/test_retryable_writes.py

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -471,17 +471,11 @@ def test_RetryableWriteError_error_label(self):
471471
'mode': {'times': 2},
472472
'data': {
473473
'failCommands': ['insert'],
474-
'closeConnection': False,
475474
'writeConcernError': {
476475
'code': 91,
477476
'errmsg': 'Replication is being shut down'},
478477
}}
479478

480-
if client_context.version < Version(4, 2):
481-
# SERVER-39292: specifying closeConnection on MongoDB 4.0+,<4.2
482-
# causes the failPoint to fire twice so we remove it.
483-
fail_insert['data'].pop('closeConnection')
484-
485479
# Ensure collection exists.
486480
client.pymongo_test.testcoll.insert_one({})
487481

0 commit comments

Comments
 (0)