Skip to content

Commit a7a2fbb

Browse files
Merge pull request #250 from ncsa/misc-utils-splits-logic
Splits logic.
2 parents 8178345 + 67c9010 commit a7a2fbb

1 file changed

Lines changed: 7 additions & 5 deletions

File tree

neat/read_simulator/utils/options.py

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -442,13 +442,15 @@ def log_configuration(self):
442442
_LOG.info(f' - splitting input into size {self.parallel_block_size}')
443443
elif self.parallel_mode == 'contig':
444444
_LOG.info(f'Splitting input by contig.')
445-
if not self.cleanup_splits or self.reuse_splits:
445+
if self.reuse_splits:
446446
splits_dir = Path(f'{self.output_dir}/splits/')
447-
if splits_dir.is_dir():
447+
if not splits_dir.is_dir():
448+
raise FileNotFoundError(f"reuse_splits=True but splits dir not found: {splits_dir}")
448449
_LOG.info(f'Reusing existing splits {splits_dir}.')
449-
else:
450-
_LOG.warning(f'Reused splits set to True, but splits dir not found: {splits_dir}. Creating new splits')
451-
_LOG.info(f'Preserving splits for next run in directory {self.splits_dir}.')
450+
_LOG.info(f'Preserving splits for next run in directory {splits_dir}.')
451+
elif not self.cleanup_splits:
452+
splits_dir = Path(f'{self.output_dir}/splits/')
453+
_LOG.info(f'Preserving splits for next run in directory {splits_dir}.')
452454
else:
453455
splits_dir = self.temp_dir_path / "splits"
454456

0 commit comments

Comments
 (0)