code: def testNcclBroadcastDoubleRecv(self):
      self._setup_context()
  
      tensor_value = [0.1, 1.1, 2.1, 3.1, 4.1, 5.1, 6.1, 7.1]
      group_key = 1
      instance_key = 1
  
      @def_function.function
      def run_nccl_broadcast_double_recv():
          for device in self._devices:
              with ops.device(device):
                  t = constant_op.constant(tensor_value)
                  collective_ops.broadcast_recv(
                      t.shape,
                      t.dtype,
                      self._group_size,
                      group_key,
                      instance_key,
                  )
  
      with self.assertRaisesRegex(
          errors.InternalError, "found no source"
      ):
          run_nccl_broadcast_double_recv()
  
imports: import os
  import threading
  import time
  from tensorflow.python.eager import context
  from tensorflow.python.eager import def_function
  from tensorflow.python.framework import config
  from tensorflow.python.framework import constant_op
  from tensorflow.python.framework import dtypes
  from tensorflow.python.framework import errors
  from tensorflow.python.framework import ops
  from tensorflow.python.framework import test_util
  from tensorflow.python.ops import collective_ops
  from tensorflow.python.platform import test
label_desc: Use image node_id 8 for calling the CollectiveOpGPUTest obj's underlying member method code with example usage: obj.testNcclBroadcastDoubleRecv() without return types