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

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

parent a7cb8638
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
Pipeline #15144 passed
......@@ -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