o 'h@ @spdZddlmZddlmZmZmZmZmZddl m Z m Z ddl m Z er,ddlmZdddZdddZdS)zRConstants, types, and classes shared across Client Bulk Write API implementations.) annotations) TYPE_CHECKINGAnyMappingMutableMappingNoReturn)ClientBulkWriteExceptionOperationFailure) _get_wce_doc) _DocumentOutops#list[tuple[str, Mapping[str, Any]]]offsetint full_resultMutableMapping[str, Any]resultMapping[str, Any]returnNonec Cs|dr |d|d<|d|dd7<|d|dd7<|d|dd7<|d|dd7<|d|dd7<|d}|rp|D]}|}|d |}||d <||d |d <|d|qPt|}|r|d |d Sd S)z?Merge result of a single bulk write batch into the full result.error nInsertedrnDeletednMatched nModified nUpserted writeErrorsidxopwriteConcernErrorsN)getcopyappendr ) r rrr write_errorsdoc replacementoriginal_indexwcer)W/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/_client_bulk_shared.py_merge_commands&    r+r verbose_resultsboolrcCs|dr-|djddd|dd}|d}|d}|dkr-|d r-d }t|||t|d trBsz4_throw_client_bulk_write_exception..)keyrcodeerrmsgzTransaction numberszrThis MongoDB deployment does not support retryable writes. Please add retryWrites=false to your connection string.r)sort startswithr isinstance BaseExceptionr)rr,errr0msgr1r)r)r*"_throw_client_bulk_write_exception<s   r9N) r r rrrrrrrr)rr r,r-rr)__doc__ __future__rtypingrrrrrpymongo.errorsrr pymongo.helpers_sharedr pymongo.typingsr r+r9r)r)r)r*s