Skip to content

Commit 95a208d

Browse files
committed
Workflow parser: Fix WORKFLOWMODE=print with calib workflows present
1 parent a21ebfb commit 95a208d

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
@@ -70,6 +70,7 @@ for line in f:
7070
reconodesmin = 0
7171
recoworkflows = []
7272
calibworkflows = []
73+
calibworkflowsdds = []
7374
print('Found topology', sys.argv[2], '-', args)
7475
if 'EPNSYNCMODE' in os.environ and int(os.environ['EPNSYNCMODE']) and (not 'GEN_TOPO_RUN_HOME' in os.environ or not int(os.environ['GEN_TOPO_RUN_HOME'])):
7576
restore_O2DPG_ROOT = 'O2DPG_ROOT' in os.environ
@@ -144,6 +145,7 @@ for line in f:
144145
continue
145146
filename = filename + ':' + wf[1]
146147
calibworkflows.append(filename)
148+
calibworkflowsdds.append(filename + ':' + wf[1])
147149
if reco_num_nodes_override > 0:
148150
reconodes = reco_num_nodes_override
149151
reconodesmin = min(reconodes, reconodesmin)
@@ -175,7 +177,7 @@ for line in f:
175177
odccommand += ' --n ' + str(reconodes)
176178
odccommand += ' --nmin ' + str(reconodesmin) # Currently disabled, since odc-epn-topo does not accept --nmin
177179
if len(calibworkflows):
178-
odccommand += ' --calib ' + ' '.join(calibworkflows)
180+
odccommand += ' --calib ' + ' '.join(calibworkflowsdds)
179181
if 'GEN_TOPO_STDERR_LOGGING' in os.environ and int(os.environ['GEN_TOPO_STDERR_LOGGING']):
180182
odccommand += ' --mon tools/monitoring_workflows/epnstderrlog.xml'
181183
if args[1] != '':

0 commit comments

Comments
 (0)