@@ -215,17 +215,29 @@ def process_all_collections(self) -> Dict[str, List[Dict]]:
215
215
216
216
# Add the overall status to each collection's results
217
217
for collection_name in results .keys ():
218
+ # Check if this collection had any errors (excluding overall_status operations)
219
+ collection_has_errors = any (
220
+ isinstance (op , dict ) and op .get ("status" ) == "error"
221
+ and op .get ("operation" ) != "overall_status"
222
+ for op in results [collection_name ]
223
+ )
224
+
225
+ # Determine this collection's status
226
+ collection_status = "error" if collection_has_errors else "success"
227
+ collection_message = "Collection processing failed" if collection_has_errors else "Collection processed successfully"
228
+
218
229
results [collection_name ].append ({
219
230
"operation" : "overall_status" ,
220
- "message" : overall_message ,
231
+ "message" : collection_message ,
221
232
"details_type" : "overall" ,
222
233
"details" : {
223
234
"collections_processed" : len (self .collection_configs ),
224
235
"collections_failed" : sum (1 for result in results .values ()
225
236
if any (isinstance (op , dict ) and op .get ("status" ) == "error"
237
+ and op .get ("operation" ) != "overall_status"
226
238
for op in result ))
227
239
},
228
- "status" : overall_status
240
+ "status" : collection_status
229
241
})
230
242
231
243
return results
0 commit comments