This is neat (and simple), thank you. I also wrote a library with a similar aim: https://github.com/candlerb/htcondor_dag.py However it's a lot more complex, because what I wanted was for each DAG node to be a python function invocation. So it pickles the arguments to each deferred function call, stores them in an input file, and each node job calls the appropriate function with the appropriate args. The code is not as clean as it could be - especially if you want to write out multiple DAGs. Regards, Brian. |