fix file upload error

2024-10-28 11:22:04 +08:00
parent 344a886792
commit 3b5a9b5220
1 changed files with 2 additions and 1 deletions
@@ -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