3
3
4
4
import os
5
5
import sys
6
+ import uuid
6
7
7
8
from .base import (GraphPluginBase , logger )
8
9
@@ -15,9 +16,11 @@ class CondorDAGManPlugin(GraphPluginBase):
15
16
The plugin_args input to run can be used to control the DAGMan execution.
16
17
Currently supported options are:
17
18
18
- - template : submit spec template to use for job submission. The template
19
- all generated submit specs are appended to this template. This
20
- can be a str or a filename.
19
+ - template : submit spec template for individual jobs in a DAG. All
20
+ generated submit spec components (e.g. executable name and
21
+ arguments) are appended to this template. This can be a str or
22
+ a filename. In the latter case the file content is used as a
23
+ template.
21
24
- submit_specs : additional submit specs that are appended to the generated
22
25
submit specs to allow for overriding or extending the defaults.
23
26
This can be a str or a filename.
@@ -53,7 +56,7 @@ def _submit_graph(self, pyfiles, dependencies, nodes):
53
56
# location of all scripts, place dagman output in here too
54
57
batch_dir , _ = os .path .split (pyfiles [0 ])
55
58
# DAG description filename
56
- dagfilename = os .path .join (batch_dir , 'workflow.dag' )
59
+ dagfilename = os .path .join (batch_dir , 'workflow-%s .dag' % uuid . uuid4 () )
57
60
with open (dagfilename , 'wt' ) as dagfileptr :
58
61
# loop over all scripts, create submit files, and define them
59
62
# as jobs in the DAG
0 commit comments