...
Brian's instructions for 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}) |
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...