notify.add_batch(batch, "SKIP")
buildlogs.flush()
- chroot.run("rm -f %s" % string.join(r.chroot_files))
+ chroot.run("rm -f %s" % r.chroot_files.join())
emails[d['Requester']] = 1
e = emails.keys()
m = mailer.Message()
- m.set_headers(to = string.join(e, ", "),
+ m.set_headers(to = e.join(", "),
subject = "[%s] builder queue problem" % config.builder)
m.write("there were problems sending files from queue %s:\n" % dir)
m.write("problems:\n")
cmd = ['/usr/bin/gpg', '--batch', '--no-tty', '--decrypt']
gpg_run = subprocess.Popen(cmd, stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE, close_fds=True)
try:
- d_stdout, d_stderr = gpg_run.communicate(buf.encode('utf-8'))
+ d_stdout, d_stderr = gpg_run.communicate(buf.decode().encode('utf-8'))
except OSError as e:
log.error("gnupg run, does gpg binary exist? : %s" % e)
raise
cmd = ['/usr/bin/gpg', '--batch', '--no-tty', '--decrypt']
gpg_run = subprocess.Popen(cmd, stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE, close_fds=True)
try:
- d_stdout, d_stderr = gpg_run.communicate(buf.encode('utf-8'))
+ d_stdout, d_stderr = gpg_run.communicate(buf.decode().encode('utf-8'))
except OSError as e:
log.error("gnupg run failed, does gpg binary exist? : %s" % e)
raise
# TODO: check for gpg return code!
gpg_run = subprocess.Popen(cmd, stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE, close_fds=True)
try:
- d_stdout, d_stderr = gpg_run.communicate(buf.encode('utf-8'))
+ d_stdout, d_stderr = gpg_run.communicate(buf.decode().encode('utf-8'))
except OSError as e:
log.error("gnupg signing failed, does gpg binary exist? : %s" % e)
raise
return errors
def upgrade_from_batch(r, b):
- f = chroot.popen("rpm --test -F %s 2>&1" % string.join(b.files), user = "root")
+ f = chroot.popen("rpm --test -F %s 2>&1" % b.files.join(), user = "root")
killset = {}
rx = re.compile(r' \(installed\) (?P<name>[^\s]+)-[^-]+-[^-]+$')
for l in f:
util.append_to(b.logfile, err)
log.notice("cannot upgrade rpms")
return False
- k = string.join(killset.keys())
+ k = killset.keys().join()
if True:
b.log_line("upgrade requires removal of %s" % k)
res = chroot.run("rpm -e %s" % k, logfile = b.logfile, user = "root")
return False
b.log_line("upgrading packages")
logbuf = StringIO.StringIO()
- res = chroot.run("rpm -Fvh %s" % string.join(b.files), user = "root", logfile = b.logfile)
+ res = chroot.run("rpm -Fvh %s" % b.files.join(), user = "root", logfile = b.logfile)
if res != 0:
b.log_line("package upgrade failed")
logbuf.close()
def dump(self, f):
f.write("group: %d (id=%s pri=%d)\n" % (self.no, self.id, self.priority))
f.write(" from: %s\n" % self.requester)
- f.write(" flags: %s\n" % string.join(self.flags))
+ f.write(" flags: %s\n" % self.flags.join())
f.write(" time: %s\n" % time.asctime(time.localtime(self.time)))
for b in self.batches:
b.dump(f)
'requester': escape(self.requester),
'priority': self.priority,
'max_jobs': self.max_jobs,
- 'flags': string.join(self.flags)
+ 'flags': self.flags.join()
})
f.write("<ol>\n")
for b in self.batches:
<requester email='%s'>%s</requester>
<time>%d</time>
<priority>%d</priority>
- <maxjobs>%d</maxjobs>\n""" % (self.id, self.no, string.join(self.flags),
+ <maxjobs>%d</maxjobs>\n""" % (self.id, self.no, self.flags.join(),
escape(self.requester_email), escape(self.requester),
self.time, self.priority, self.max_jobs))
for b in self.batches:
builders = []
for b in self.builders:
builders.append("%s:%s" % (b, self.builders_status[b]))
- f.write(" builders: %s\n" % string.join(builders))
+ f.write(" builders: %s\n" % builders.join())
def is_command(self):
return self.command != ""
'tooltip' : cgi.escape(tooltip, True),
}
+ link_post)
- f.write("%s]</small></li>\n" % string.join(builders))
+ f.write("%s]</small></li>\n" % builders.join())
def rpmbuild_opts(self):
"""
<spec>%s</spec>
<branch>%s</branch>
<info>%s</info>\n""" % (self.b_id,
- string.join(list(map(lambda b: b.b_id, self.depends_on))),
+ list(map(lambda b: b.b_id, self.depends_on)).join(),
escape(self.src_rpm),
escape(' '.join(self.command_flags)), escape(self.command),
escape(self.spec), escape(self.branch), escape(self.info)))
batch.builders_status_time[bld] = time.time()
if bld not in config.binary_builders and bld != config.builder:
fail_mail("I (src rpm builder '%s') do not handle binary builder '%s', only '%s'" % \
- (config.builder, bld, string.join(config.binary_builders)))
+ (config.builder, bld, config.binary_builders.join()))
lockf.close()
return
if batch.is_command():
b.log_line("copy rpm files to cache_dir: %s" % rpm_cache_dir)
chroot.run(
"cp -f %s %s && poldek --mo=nodiff --mkidxz -s %s/" % \
- (string.join(b.files), rpm_cache_dir, rpm_cache_dir),
+ (b.files.join(), rpm_cache_dir, rpm_cache_dir),
logfile = b.logfile, user = "root"
)
else: