code: def _broadcast_to_followers(sequence_id, objects_map):
      with _all_gather_dict_lock:
          states = _all_gather_sequence_id_to_states[sequence_id]
  
      assert (
          not states.proceed_signal.is_set()
      ), f"Termination signal sequence id {sequence_id} got set twice."
      states.gathered_objects = objects_map
      states.proceed_signal.set()
  
imports: import collections
  import contextlib
  import functools
  import inspect
  import logging
  import threading
  from typing import Dict, Generic, TypeVar, Set, Any, TYPE_CHECKING
  import torch
  from torch.futures import Future
  from torch._C._distributed_rpc import PyRRef, RemoteProfilerManager, WorkerInfo, TensorPipeAgent, get_rpc_timeout, _cleanup_python_rpc_handler, _delete_all_user_and_unforked_owner_rrefs, _destroy_rref_context, _get_current_rpc_agent, _invoke_remote_builtin, _invoke_remote_python_udf, _invoke_remote_torchscript, _invoke_rpc_builtin, _invoke_rpc_python_udf, _invoke_rpc_torchscript, _is_current_rpc_agent_set, _reset_current_rpc_agent, _set_and_start_rpc_agent
  from .internal import PythonUDF, RPCExecMode, _internal_rpc_pickler, _build_rpc_profiling_key
  from .constants import DEFAULT_SHUTDOWN_TIMEOUT, UNSET_RPC_TIMEOUT
  from ._utils import _group_membership_management, _update_group_membership
label_desc: Use image node_id 5 for calling a global function with example usage: _broadcast_to_followers(sequence_id, objects_map) without return types