def UpdateQueues(self):
    """Updates any new or changed task queue definitions."""
    if len(self.args) != 1:
      self.parser.error('Expected a single <directory> argument.')

    basepath = self.args[0]
    appyaml = self._ParseAppYaml(basepath)
    rpc_server = self._GetRpcServer()

    queue_entries = self._ParseQueueYaml(basepath)
    if queue_entries:
      queue_upload = QueueEntryUpload(rpc_server, appyaml, queue_entries)
      queue_upload.DoUpload()
dataset/ETHPy150Open CollabQ/CollabQ/.google_appengine/google/appengine/tools/appcfg.py/AppCfgApp.UpdateQueues/original