grim/local-pipelines

This basically works, needs a lot of polishing yet, but it works ;)
--- a/pipelines/pipeline.py Tue Jun 28 16:52:30 2016 -0500
+++ b/pipelines/pipeline.py Tue Jun 28 20:30:16 2016 -0500
@@ -30,7 +30,8 @@
fd, filename = tempfile.mkstemp(prefix='pipeline', suffix='.sh')
with os.fdopen(fd, "w") as ofp:
- ofp.writelines(step['script'])
+ content = " && \\\n".join(step["script"])
+ ofp.write(content)
return filename
@@ -60,7 +61,10 @@
def _commands(self):
commands = []
- for step in self.steps:
+ print(self.steps)
+ print('-'*40)
+ for container in self.steps:
+ step = container["step"]
commands.append(self.get_command(step))
return commands