Skip to content

Commit 096cf00

Browse files
committed
Workflow parser: misc fixes + improve error message
1 parent f536e9f commit 096cf00

File tree

1 file changed

+7
-9
lines changed

1 file changed

+7
-9
lines changed

DATA/tools/parse

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -123,31 +123,29 @@ for line in f:
123123
if os.environ['WORKFLOWMODE'] == 'print':
124124
command += ' > ' + filename
125125
print('Running DPL command', command)
126-
if reco_num_nodes_override == 0:
127-
os.environ['RECO_NUM_NODES_WORKFLOW'] = wf[1]
128-
if os.system(command) != 0:
129-
print('Error running command', command)
126+
retVal = os.system(command)
127+
if retVal != 0:
128+
print('Error (' + str(retVal) + ') running command', command)
130129
ftmp = open(filename, 'r')
131130
rg = re.compile('^<topology')
132131
for line in ftmp:
133132
if re.match(rg, line):
134133
break
135-
print(line)
134+
print(line, end='')
136135
raise
137136
if args[i].startswith('reco'):
138137
recoworkflows.append(filename)
139138
elif args[i].startswith('calib'):
140139
if os.environ['WORKFLOWMODE'] == 'dds':
141-
isempty = 1
140+
isempty = 1
142141
ftmp = open(filename, 'r')
143142
rg = re.compile('^.*<decltask')
144143
for line in ftmp:
145144
if re.match(rg, line):
146145
isempty = 0
147146
break
148-
if isempty:
149-
continue
150-
filename = filename + ':' + wf[1]
147+
if isempty:
148+
continue
151149
calibworkflows.append(filename)
152150
calibworkflowsdds.append(filename + ':' + wf[1])
153151
if reco_num_nodes_override > 0:

0 commit comments

Comments
 (0)