Dynamic dispatch of a list of command-line tasks, locally or on a cluster. Supports retrying failed tasks, and adding/removing compute resources on-the-fly.
As far as I can tell, stdout=SUB.PIPE, stderr=SUB.PIPE is exactly equivalent to capture_output=True, so this a pretty straightforward change. I tested on Python 3.6 and 3.9.
As far as I can tell,
stdout=SUB.PIPE, stderr=SUB.PIPEis exactly equivalent tocapture_output=True, so this a pretty straightforward change. I tested on Python 3.6 and 3.9.Also fixes a typo in one of the log levels.