...
Converting scriptlets to batch jobs (NB: the code block below has been corrected, but not checked. Here's the link to bvan's original slack message):
Code Block |
---|
#!/usr/bin/env python3
import os
class Pipeline:
def setVariable(self, key, value):
with open(os.environ["PIPELINE_SUMMARY"], "a") as f:
f.write("Pipeline.%s: %s\n" %(key, value))
def createStream(self, task, stream, args):
with open(os.environ["PIPELINE_SUMMARY"], "a") as f:
f.write("PipelineCreateStream.%s.%d: %s\n" %(task, int(stream), args))
pipeline = Pipeline()
locals().update({k:v for k,v in os.environ.items() if "." not in k}) |
...