Publish a CommandSucceededEvent.
(self, request_id: int, reply: _DocumentOut, duration: datetime.timedelta)
| 637 | return self.max_bson_size |
| 638 | |
| 639 | def _succeed(self, request_id: int, reply: _DocumentOut, duration: datetime.timedelta) -> None: |
| 640 | """Publish a CommandSucceededEvent.""" |
| 641 | self.listeners.publish_command_success( |
| 642 | duration, |
| 643 | reply, |
| 644 | self.name, |
| 645 | request_id, |
| 646 | self.conn.address, |
| 647 | self.conn.server_connection_id, |
| 648 | self.op_id, |
| 649 | self.conn.service_id, |
| 650 | database_name=self.db_name, |
| 651 | ) |
| 652 | |
| 653 | def _fail(self, request_id: int, failure: _DocumentOut, duration: datetime.timedelta) -> None: |
| 654 | """Publish a CommandFailedEvent.""" |
no test coverage detected