diff --git a/file_upload.py b/file_upload.py index fd471fe..a936f6a 100644 --- a/file_upload.py +++ b/file_upload.py @@ -95,7 +95,8 @@ def process_local_file_path_async(mapping_dict, max_workers=10): result = future.result() mapping_dict[filename] = result except Exception as e: - print(f"Error processing {filename}: {e}") + del mapping_dict[filename] + raise NotImplementedError(f"Error processing {filename}: {e}") end_time = time.time() logging.info(f"upload end, elapsed time: {end_time - start_time}") return \ No newline at end of file