34
34
)
35
35
from ..data_readers import KaldiFrameIdentifier , KaldiMatrixIdentifier
36
36
from ..utils import (
37
- get_path , OrderedSet , cast_to_bool , is_relative_to , start_telemetry , send_telemetry_event , end_telemetry
37
+ get_path , OrderedSet , cast_to_bool , is_relative_to , start_telemetry , send_telemetry_event ,
38
+ end_telemetry , AtomicWriteFileHandle
38
39
)
39
40
from ..data_analyzer import BaseDataAnalyzer
40
41
from .format_converter import BaseFormatConverter
@@ -327,7 +328,7 @@ def save_annotation(annotation, meta, annotation_file, meta_file, dataset_config
327
328
annotation_dir = annotation_file .parent
328
329
if not annotation_dir .exists ():
329
330
annotation_dir .mkdir (parents = True )
330
- with annotation_file . open ( 'wb' ) as file :
331
+ with AtomicWriteFileHandle ( annotation_file , 'wb' ) as file :
331
332
if conversion_meta :
332
333
pickle .dump (conversion_meta , file )
333
334
for representation in annotation :
@@ -337,7 +338,7 @@ def save_annotation(annotation, meta, annotation_file, meta_file, dataset_config
337
338
meta_dir = meta_file .parent
338
339
if not meta_dir .exists ():
339
340
meta_dir .mkdir (parents = True )
340
- with meta_file . open ( 'wt' ) as file :
341
+ with AtomicWriteFileHandle ( meta_file , 'wt' ) as file :
341
342
json .dump (meta , file )
342
343
343
344
0 commit comments