Skip to content
Snippets Groups Projects
Commit de1458e6 authored by Daniel Nemergut's avatar Daniel Nemergut
Browse files

Merge branch 'ws2227-recycle_raw_data_fix' into 'main'

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

See merge request !1631
parents a7cb8638 05cd0de8
No related branches found
No related tags found
2 merge requests!1669Catchup with main,!1631Fixed conveyor move logic to skip directories that already existed in the spool
......@@ -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:
"""
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment