Skip to content

Commit 26a8d87

Browse files
authored
Merge pull request #445 from JeffersonLab/iss444_bug_fixes
This fixes the bugs mentioned in iss444
2 parents 626c7ad + 51e070f commit 26a8d87

2 files changed

Lines changed: 12 additions & 9 deletions

File tree

python/hpsmc/job.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -295,15 +295,15 @@ def parse_args(self):
295295
if not os.path.isabs(out_file):
296296
out_file = os.path.abspath(out_file)
297297
logger.info('Job output will be written to: %s' % out_file)
298-
self.out = open(out_file, 'w')
298+
self.component_out = open(out_file, 'w')
299299

300300
# Set file for stderr from components
301301
if cl.err:
302302
err_file = cl.err
303303
if not os.path.isabs(err_file):
304304
err_file = os.path.abspath(err_file)
305305
logger.info('Job error will be written to: %s' % err_file)
306-
self.err = open(err_file, 'w')
306+
self.component_err = open(err_file, 'w')
307307

308308
if cl.run_dir:
309309
self.rundir = os.path.abspath(cl.run_dir)
@@ -335,6 +335,8 @@ def parse_args(self):
335335
# Load data from a JSON file with a single job definition.
336336
logger.info('Loading job parameters from file: %s' % self.param_file)
337337
params = json.loads(open(self.param_file, 'r').read())
338+
if isinstance(params, list):
339+
params = params[0]
338340
if not isinstance(params, dict):
339341
raise Exception('Job ID must be provided when running from a job store.')
340342

python/hpsmc/tools.py

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -458,7 +458,7 @@ def __init__(self, **kwargs):
458458
self.input_file = None
459459
self.minidst_args = None
460460
# Ensure to call the parent constructor properly
461-
Component.__init__(self, name='makeminidst',
461+
Component.__init__(self, name='make_mini_dst',
462462
command='make_mini_dst',
463463
description='Create the MiniDST ROOT file',
464464
output_ext='.root',
@@ -504,7 +504,8 @@ def output_files(self):
504504
"""! Adjust names of output files."""
505505
if self.outputs is None:
506506
f, ext = os.path.splitext(self.input_files()[0])
507-
self.outputs = f"{f}.root"
507+
self.outputs = f"{f}_minidst.root"
508+
print(f"Set outputs to: {self.outputs}")
508509

509510
return self.outputs
510511

@@ -515,16 +516,16 @@ def cmd_args(self):
515516
"""
516517
args = []
517518

518-
print("===== Make MiniDST with input files: ", end="")
519+
print("===== Make MiniDST with input files: ", end=" ")
519520
for i in range(len(self.input_files())):
520521
print(f"{self.input_files()[i]}", end=", ")
521-
print(f" -> {self.output_files()}")
522+
print(f" ==> {self.output_files()}")
522523

523-
args.extend(self.minidst_args)
524+
if self.minidst_args is not None:
525+
args.extend(self.minidst_args)
524526

525-
args.extend(['-o', self.output_files()[0]])
527+
args.extend(['-o', self.output_files()])
526528
args.extend(self.input_files())
527-
528529
return args
529530

530531

0 commit comments

Comments
 (0)