def process_results(self):
print "[ +D+ ] - Begin processing minimization results"
bs = beanstalkc.Connection(host='127.0.0.1', port=11300)
bs.use('min-results')
if self.get_job():
seed = msgpack.unpackb(zlib.decompress(self.job.body))
name = seed['seed_name']
data = seed['data']
filename = os.path.join(self.min_dir, name)
with open(filename, 'wb') as f:
f.write(data)
评论列表
文章目录