code: def test_run_on_leader_decorator(self) -> None:
      self._run_multi_process_test(
          world_size=self.WORLD_SIZE,
          backend="gloo",
          # pyre-ignore [6]
          callable=self._test_run_on_leader_decorator,
      )
  
imports: import multiprocessing
  import os
  import unittest
  from typing import Callable
  from unittest import mock
  import torch.distributed
  from torch._utils_internal import TEST_MASTER_ADDR
  from torchrec.distributed.collective_utils import invoke_on_rank_and_broadcast_result, is_leader, run_on_leader
  from torchrec.test_utils import get_free_port, seed_and_log
label_desc: Use image node_id 9 for calling the CollectiveUtilsTest obj's underlying member method code with example usage: obj.test_run_on_leader_decorator() without return types