async def broadcast_attestation(self, attestation: Attestation) -> None:
    (await self._broadcast_data(PUBSUB_TOPIC_BEACON_ATTESTATION, ssz.encode(attestation)))
async def broadcast_attestation(self, attestation: Attestation) -> None:
    (await self._broadcast_data(PUBSUB_TOPIC_BEACON_ATTESTATION, ssz.encode(attestation)))