parameters: (self, batch_t, data)
docstring: Get a batch at time t, reply with data
docstring_summary: Get a batch at time t, reply with data
docstring_tokens: Get a batch at time t reply with data
function: def reply(self, batch_t, data):
          ''' Get a batch at time t, reply with data'''
          if data is None: return
  
          n = batch_t["_batchsize"]
          senders = batch_t["_sender"][:n]
          agent_names = batch_t["_agent_name"][:n]
          keys = batch_t["_key"][:n]
          seqs = batch_t["_seq"][:n]
          game_counters = batch_t["_game_counter"][:n]
  
          all_data = []
          for i, (identity, agent_name, seq, key, game_counter) in enumerate(zip(senders, agent_names, seqs, keys, game_counters)):
              this_data = dict(_sender=identity, _agent_name=agent_name, _seq=seq, _key=key, _game_counter=game_counter)
              for k, v in data.items():
                  this_data.update({ k : v[i]})
              # print("Reply[%d]: %s" % (i, str(this_data)))
              all_data.append(this_data)
          queue_put(self.reply_queue, all_data, fail_comment="BatchConnector.reply.queue_put failed, retrying...")
function_tokens: def reply ( self , batch_t , data ) : if data is None : return n = batch_t [ "_batchsize" ] senders = batch_t [ "_sender" ] [ : n ] agent_names = batch_t [ "_agent_name" ] [ : n ] keys = batch_t [ "_key" ] [ : n ] seqs = batch_t [ "_seq" ] [ : n ] game_counters = batch_t [ "_game_counter" ] [ : n ] all_data = [ ] for i , ( identity , agent_name , seq , key , game_counter ) in enumerate ( zip ( senders , agent_names , seqs , keys , game_counters ) ) : this_data = dict ( _sender = identity , _agent_name = agent_name , _seq = seq , _key = key , _game_counter = game_counter ) for k , v in data . items ( ) : this_data . update ( { k : v [ i ] } ) # print("Reply[%d]: %s" % (i, str(this_data))) all_data . append ( this_data ) queue_put ( self . reply_queue , all_data , fail_comment = "BatchConnector.reply.queue_put failed, retrying..." )