Debugging dump of the pipe.
Returns a list of lines.
"""
- l=["%s >>> Pipeline %s\n" % (prefix, self.name)]
+ l=["%s >>> Pipeline %s" % (prefix, self.name)]
for pri, name, fun in self.pipe:
- l.append("%s% 3d %s, %s\n" % (prefix, pri, name, fun))
+ l.append("%s% 3d %s, %s" % (prefix, pri, name, fun))
+ return l
def run(self, *args, **kwargs):
self.index = 0
while self.index < len(self.pipe):
(pri,name,fun) = self.pipe[self.index]
if pri >= min_pri:
- self.e.log.debug("Pipeline %r:%d running: %s\n" % (self.name, pri, name))
+ self.e.log.debug("Pipeline %r:%d running: %s" % (self.name, pri, name))
try:
fun(*args, **kwargs)
except MoeAbortPipeline, err:
min_pri = self.skip_to
else:
- self.e.log.debug("Pipeline %r:d skipping: %s\n" % (self.name, pri, name))
+ self.e.log.debug("Pipeline %r:d skipping: %s" % (self.name, pri, name))
self.index += 1
self.index = -1
- self.e.log.debug("Pipeline %r finished\n" % (self.name))
+ self.e.log.debug("Pipeline %r finished" % (self.name))