async def _try_restart_pyre_server(self) -> None:
    if (self.state.consecutive_start_failure < CONSECUTIVE_START_ATTEMPT_THRESHOLD):
        (await self.pyre_manager.ensure_task_running())
    else:
        LOG.info('Not restarting Pyre since failed consecutive start attempt limit has been reached.')
async def _try_restart_pyre_server(self) -> None:
    if (self.state.consecutive_start_failure < CONSECUTIVE_START_ATTEMPT_THRESHOLD):
        (await self.pyre_manager.ensure_task_running())
    else:
        LOG.info('Not restarting Pyre since failed consecutive start attempt limit has been reached.')