Skip to content
Snippets Groups Projects

Fixed conveyor move logic to skip directories that already existed in the spool

Merged Daniel Nemergut requested to merge ws2227-recycle_raw_data_fix into main
1 file
+ 6
3
Compare changes
  • Side-by-side
  • Inline
@@ -126,9 +126,12 @@ class RetrievalConveyor(ConveyorIF):
for directory in dir_list:
qa_dir = qa_path / directory
spool_dir = spool_path / directory
self.logger.info(f"Moving directory {directory}...")
shutil.move(qa_dir, spool_dir)
self.logger.info("Done.")
if spool_dir.exists():
self.logger.info(f"Directory {directory} already existed in spool. Skipping.")
else:
self.logger.info(f"Moving directory {directory}...")
shutil.move(qa_dir, spool_dir)
self.logger.info("Done.")
def determine_qa_directory(self) -> Path:
"""
Loading