code: def __init__(self, broker_addr, index):
      self.rpc = moolib.Rpc()
      self.rpc.set_name("client %d" % index)
      self.rpc.set_timeout(20)
      self.rpc.connect(broker_addr)
      self.group = None
      self.index = index
      self.reduce = None
      self.sum = None
      self.reduce_counter = 0
  
file_path: moolib/test/test_reduce.py
imports: import moolib
  import time
  import torch
  import random
label_desc: Use image node_id 1 to create a new Client object  with example: obj = Client(broker_addr, index)