Skip to content

Commit fa969a7

Browse files
committed
Workflow parser: fix number of cores for calib workflow propagation
1 parent a884109 commit fa969a7

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

DATA/tools/parse

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,12 +99,14 @@ for line in f:
9999
raise
100100
for i in range(2, len(args)):
101101
filename = tmpdir + '/wf' + str(i) + '.dds'
102+
calibcores = '1'
102103
if args[i].startswith('reco'):
103104
wf = args[i].split(',', 3)
104105
is_calib_workflow = 0
105106
elif args[i].startswith('calib'):
106107
wf = args[i].split(',', 2)
107108
wf.append(wf[2])
109+
calibcores = wf[1]
108110
wf[1] = '1';
109111
wf[2] = wf[1]
110112
is_calib_workflow = 1
@@ -147,7 +149,7 @@ for line in f:
147149
if isempty:
148150
continue
149151
calibworkflows.append(filename)
150-
calibworkflowsdds.append(filename + ':' + wf[1])
152+
calibworkflowsdds.append(filename + ':' + calibcores)
151153
if reco_num_nodes_override > 0:
152154
reconodes = reco_num_nodes_override
153155
reconodesmin = min(reconodes, reconodesmin)

0 commit comments

Comments
 (0)