'Updates any new or changed task queue definitions.'

def UpdateQueues(self):

    if self.args:
        self.parser.error('Expected    a    single    <directory>    argument.')
    rpcserver = self._GetRpcServer()
    queue_yaml = self._ParseQueueYaml(self.basepath)
    if queue_yaml:
        queue_upload = QueueEntryUpload(rpcserver, queue_yaml, self.error_fh)
        queue_upload.DoUpload()
    else:
        print >>self.error_fh, 'Could    not    find    queue    configuration.    No    action    taken.'
