Method retryable_bulk

pymongo/asynchronous/bulk.py:590–601

(
            session: Optional[AsyncClientSession], conn: AsyncConnection, retryable: bool
        )

        op_id = _randint()

        async def retryable_bulk(
            session: Optional[AsyncClientSession], conn: AsyncConnection, retryable: bool
        ) -> None:
            await self._execute_command(
                generator,
                write_concern,
                session,
                conn,
                op_id,
                retryable,
                full_result,
            )

        client = self.collection.database.client
        _ = await client._retryable_write(