code: def __readCommissioningLogs(self, durationInSeconds):
          
          self.logThreadStatus = self.logStatus['running']
          logs = Queue()
          t_end = time.time() + durationInSeconds
          while time.time() < t_end:
              time.sleep(0.3)
  
              if self.logThreadStatus == self.logStatus['pauseReq']:
                  self.logThreadStatus = self.logStatus['paused']
  
              if self.logThreadStatus != self.logStatus['running']:
                  continue
  
              try:
                  line = self._readline()
                  if line:
                      print line
                      logs.put(line)
  
                      if "Join success" in line:
                          self.joinCommissionedStatus = self.joinStatus['succeed']
                          break
                      elif "Join failed" in line:
                          self.joinCommissionedStatus = self.joinStatus['failed']
                          break
  
              except Exception:
                  pass
  
          self.logThreadStatus = self.logStatus['stop']
          return logs
docs: read logs during the commissioning process
  
          Args:
              durationInSeconds: time duration for reading commissioning logs
  
          Returns:
              Commissioning logs