@execute_task
@peer_required
@api_request
async def new_peak(self, request: full_node_protocol.NewPeak, peer: ws.WSChiaConnection) -> Optional[Message]:
    "\n        A peer notifies us that they have added a new peak to their blockchain. If we don't have it,\n        we can ask for it.\n        "
    waiter_count = len(self.full_node.new_peak_sem._waiters)
    if (waiter_count > 0):
        self.full_node.log.debug(f'new_peak Waiters: {waiter_count}')
    if (waiter_count > 20):
        return None
    async with self.full_node.new_peak_sem:
        return (await self.full_node.new_peak(request, peer))
A peer notifies us that they have added a new peak to their blockchain. If we don't have it,
we can ask for it.
@execute_task
@peer_required
@api_request
async def new_peak(self, request: full_node_protocol.NewPeak, peer: ws.WSChiaConnection) -> Optional[Message]:
    "\n        A peer notifies us that they have added a new peak to their blockchain. If we don't have it,\n        we can ask for it.\n        "
    waiter_count = len(self.full_node.new_peak_sem._waiters)
    if (waiter_count > 0):
        self.full_node.log.debug(f'new_peak Waiters: {waiter_count}')
    if (waiter_count > 20):
        return None
    async with self.full_node.new_peak_sem:
        return (await self.full_node.new_peak(request, peer))