File tree Expand file tree Collapse file tree 1 file changed +6
-4
lines changed
Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -136,9 +136,10 @@ def export_func(ctx: dict, items: List[Any]):
136136 if span_retry_queue :
137137 for span in spans :
138138 span_retry_queue .enqueue (span , span .bytes_size )
139+ err_msg = f'{ msg } , retry later'
139140 else :
140- is_fail = True
141- err_msg = msg
141+ err_msg = f' { msg } , retry second time failed'
142+ is_fail = True
142143 else :
143144 for file in upload_files :
144145 if file and file_queue :
@@ -170,9 +171,10 @@ def export_func(ctx: dict, items: List[Any]):
170171 if file_retry_queue :
171172 for file in files :
172173 file_retry_queue .enqueue (file , len (file .data ))
174+ err_msg = f'{ msg } , retry later'
173175 else :
174- is_fail = True
175- err_msg = msg
176+ err_msg = f' { msg } , retry second time failed'
177+ is_fail = True
176178 if finish_event_processor :
177179 finish_event_processor (FinishEventInfo (
178180 event_type = "exporter.file_flush.rate" ,
You can’t perform that action at this time.
0 commit comments