File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -42,13 +42,17 @@ def upload_data(db: Database, filename: Path) -> None:
42
42
db .name ,
43
43
collection_name ,
44
44
)
45
- db [collection_name ].delete_many ({})
45
+ collections = [c ["name" ] for c in db .list_collections ()]
46
+ if collection_name in collections :
47
+ logger .debug ("Clearing existing collection" , collection_name )
48
+ db [collection_name ].delete_many ({})
49
+
46
50
if not isinstance (loaded_collection , list ):
47
51
loaded_collection = [loaded_collection ]
48
52
if loaded_collection :
49
53
result : InsertManyResult = db [collection_name ].insert_many (loaded_collection )
50
54
logger .debug ("Uploaded results for %s: %s" , filename .name , result .inserted_ids )
51
- else :
55
+ elif collection_name not in collections :
52
56
logger .debug ("Empty collection named %s created" , collection_name )
53
57
db .create_collection (collection_name )
54
58
You can’t perform that action at this time.
0 commit comments