Internal delete helper.
(
self,
criteria: Mapping[str, Any],
multi: bool,
write_concern: Optional[WriteConcern] = None,
op_id: Optional[int] = None,
ordered: bool = True,
collation: Optional[_CollationIn] = None,
hint: Optional[_IndexKeyHint] = None,
session: Optional[ClientSession] = None,
let: Optional[Mapping[str, Any]] = None,
comment: Optional[Any] = None,
)
| 1551 | return result |
| 1552 | |
| 1553 | def _delete_retryable( |
| 1554 | self, |
| 1555 | criteria: Mapping[str, Any], |
| 1556 | multi: bool, |
| 1557 | write_concern: Optional[WriteConcern] = None, |
| 1558 | op_id: Optional[int] = None, |
| 1559 | ordered: bool = True, |
| 1560 | collation: Optional[_CollationIn] = None, |
| 1561 | hint: Optional[_IndexKeyHint] = None, |
| 1562 | session: Optional[ClientSession] = None, |
| 1563 | let: Optional[Mapping[str, Any]] = None, |
| 1564 | comment: Optional[Any] = None, |
| 1565 | ) -> Mapping[str, Any]: |
| 1566 | """Internal delete helper.""" |
| 1567 | |
| 1568 | def _delete( |
| 1569 | session: Optional[ClientSession], conn: Connection, retryable_write: bool |
| 1570 | ) -> Mapping[str, Any]: |
| 1571 | return self._delete( |
| 1572 | conn, |
| 1573 | criteria, |
| 1574 | multi, |
| 1575 | write_concern=write_concern, |
| 1576 | op_id=op_id, |
| 1577 | ordered=ordered, |
| 1578 | collation=collation, |
| 1579 | hint=hint, |
| 1580 | session=session, |
| 1581 | retryable_write=retryable_write, |
| 1582 | let=let, |
| 1583 | comment=comment, |
| 1584 | ) |
| 1585 | |
| 1586 | return self._database.client._retryable_write( |
| 1587 | (write_concern or self.write_concern).acknowledged and not multi, |
| 1588 | _delete, |
| 1589 | session, |
| 1590 | operation=_Op.DELETE, |
| 1591 | ) |
| 1592 | |
| 1593 | def delete_one( |
| 1594 | self, |
no test coverage detected