if _isDone(session, task_id):

                  tasklist.remove(task_id)

              # convert to list of (file, volume)

              files = []

              for filename, volumes in output.iteritems():

          time.sleep(options.poll_interval)

  def handle_add_group(options, session, args):

      "[admin] Add a group to a tag"

      usage = _("usage: %prog add-group <tag> <group>")

      buildroot_infos = session.listBuildroots(taskID=task_id)

      build_info = session.listBuilds(taskID=task_id)

      logs = []

      output = []

      for filename in files:

          task_info = session.getTaskInfo(task_id)

          if task_info is None:

              error(_("No such task id: %i" % task_id))

          logs = [] # list of tuples (filename, volume)

          for filename in files:

              if not filename.endswith(".log"):

      downloads = []

      for task in downloadable_tasks:

          for filename in files:

              if filename.endswith(".log") and suboptions.logs:

                  for volume in files[filename]:

          print("User interrupt: canceling runroot task")

          session.cancelTask(task_id)

          raise

      if 'runroot.log' in output:

          for volume in output['runroot.log']:

              log = session.downloadTaskOutput(task_id, 'runroot.log', volume=volume)

          full_chksum = util.adler32_constructor()

          # cycle is need to run at least once (for empty files)

          first_cycle = True

          while True:

              lap = time.time()

              chunk = fo.read(blocksize)

              if not chunk and not first_cycle:

                  break

              first_cycle = False

              if self.retries > 1:

                  problems = True

              hexdigest = util.adler32_constructor(chunk).hexdigest()

                  callback(ofs, size, len(chunk), t1, t2)

          if ofs != size:

              self.logger.error("Local file changed size: %s, %s -> %s", localfile, size, ofs)

          if problems:

              chk_opts['verify'] = 'adler32'

          result = self._callMethod('checkUpload', (path, name), chk_opts)

          if name is None:

              name = os.path.basename(localfile)

          # check if server supports fast upload

          try:

              # fast upload was introduced in 1.7.1, earlier servers will not

              # recognise this call and return an error

          except GenericError:

              while True:

                  if debug:

                      self.logger.debug("uploadFile(%r,%r,%r,%r,%r,...)" %(path, name, sz, digest, offset))

                      break

                  if tries <= retries:

                      tries += 1

          """

          if self.multicall:

              raise GenericError('downloadTaskOutput() may not be called during a multicall')

          return base64.decodestring(result)

  class DBHandler(logging.Handler):