docs: async def wait_for_election_success(cls):
          """Await this function if your cluster must have a leader"""
          if cls.leader is None:
              cls.leader_future = asyncio.Future(loop=cls.loop)
              await cls.leader_future