|
|
@@ -48,6 +48,9 @@ def watch_pass(input_directory: pathlib.Path, work_directory: pathlib.Path, ia_c |
|
|
|
logging.warning("Stopped upload but files remain, moving back to queue...") |
|
|
|
try: |
|
|
|
new_directory.rename(original_directory) |
|
|
|
mj = original_directory.joinpath("__upload_meta.json") |
|
|
|
if mj.exists(): |
|
|
|
os.remove(mj) |
|
|
|
except FileNotFoundError: |
|
|
|
logging.warning(f"Unable to move item {new_directory}") |
|
|
|
|
|
|
|