@@ -110,6 +110,7 @@ def _build_and_write_result(ctx: PointerDeletionContext) -> Dict[str, Any]:
110110 },
111111 "failed_deletes" : {"count" : len (ctx .failed_deletes ), "ids" : ctx .failed_deletes },
112112 "deletes-took-secs" : timedelta .total_seconds (ctx .end_time - ctx .start_time ),
113+ "output_file_path" : ctx .output_file_path ,
113114 }
114115 try :
115116 _write_result_file (result , ctx .output_file_path )
@@ -133,6 +134,33 @@ def _write_result_file(result: Dict[str, Any], output_file: str) -> None:
133134 os .replace (tf .name , output_file )
134135
135136
137+ def _print_summary (result : Dict [str , Any ]) -> None :
138+
139+ def count_from (field ):
140+ val = result .get (field )
141+ if isinstance (val , dict ):
142+ return val .get ("count" , 0 )
143+ if isinstance (val , list ):
144+ return len (val )
145+ return 0
146+
147+ print ("*******************************************************" )
148+ print ("Summary:" )
149+ print (f" pointers_to_delete: { result .get ('pointers_to_delete' )} " )
150+ print (f" ods_code_matched: { count_from ('ods_code_matched' )} " )
151+ print (f" ods_code_mismatched:{ count_from ('ods_code_mismatched' )} " )
152+ print (f" pointer_not_found: { count_from ('pointer_not_found' )} " )
153+ print (f" deleted_pointers: { count_from ('deleted_pointers' )} " )
154+ print (f" failed_deletes: { count_from ('failed_deletes' )} " )
155+ if "_output_error" in result :
156+ print (f" output_error: { result ['_output_error' ]} " )
157+ if "deletes-took-secs" in result :
158+ print (f" deletes-took-secs: { result .get ('deletes-took-secs' )} " )
159+ if "output_file_path" in result :
160+ print (f" See output file for full results: { result .get ('output_file_path' )} " )
161+ print ("*******************************************************" )
162+
163+
136164def _check_pointers_match_ods_code (
137165 ods_code : str , pointer_ids : List [str ]
138166) -> tuple [List [str ], List [str ]]:
@@ -228,29 +256,6 @@ def _batch_delete_pointers(
228256 return pointers_deleted , sorted (failed_deletes_set )
229257
230258
231- def _print_summary (result : Dict [str , Any ]) -> None :
232-
233- def count_from (field ):
234- val = result .get (field )
235- if isinstance (val , dict ):
236- return val .get ("count" , 0 )
237- if isinstance (val , list ):
238- return len (val )
239- return 0
240-
241- print ("Summary:" )
242- print (f" pointers_to_delete: { result .get ('pointers_to_delete' )} " )
243- print (f" ods_code_matched: { count_from ('ods_code_matched' )} " )
244- print (f" ods_code_mismatched:{ count_from ('ods_code_mismatched' )} " )
245- print (f" pointer_not_found: { count_from ('pointer_not_found' )} " )
246- print (f" deleted_pointers: { count_from ('deleted_pointers' )} " )
247- print (f" failed_deletes: { count_from ('failed_deletes' )} " )
248- if "_output_error" in result :
249- print (f" output_error: { result ['_output_error' ]} " )
250- if "deletes-took-secs" in result :
251- print (f" deletes-took-secs: { result .get ('deletes-took-secs' )} " )
252-
253-
254259def _delete_pointers_by_id (
255260 table_name : str ,
256261 ods_code : str ,
0 commit comments