async def delete(self, db):
        ''' Delete document '''
        for i in self.connection_retries():
            try:
                return await db[self.get_collection_name()].delete_one({self.primary_key: self.pk})
            except ConnectionFailure as ex:
                exceed = await self.check_reconnect_tries_and_wait(i, 'delete')
                if exceed:
                    raise ex