@@ -207,14 +207,12 @@ def process_delayed_heartbeat_spans(self) -> None:
207
207
self .delayed_heartbeat_spans .get ()
208
208
209
209
span = self .active_spans .get (span_id )
210
- if not span :
211
- continue
210
+ if span :
211
+ spans_to_be_logged . append ( span )
212
212
213
- spans_to_be_logged .append (span )
214
-
215
- next_heartbeat_time = now + datetime .timedelta (
216
- milliseconds = self .heartbeat_interval_millis )
217
- self .ready_heartbeat_spans .put ((span_id , next_heartbeat_time ))
213
+ next_heartbeat_time = now + datetime .timedelta (
214
+ milliseconds = self .heartbeat_interval_millis )
215
+ self .ready_heartbeat_spans .put ((span_id , next_heartbeat_time ))
218
216
219
217
for span in spans_to_be_logged :
220
218
self .export_log (span , self .get_heartbeat_attributes ())
@@ -234,14 +232,12 @@ def process_ready_heartbeat_spans(self) -> None:
234
232
self .ready_heartbeat_spans .get ()
235
233
236
234
span = self .active_spans .get (span_id )
237
- if not span :
238
- continue
239
-
240
- spans_to_be_logged .append (span )
235
+ if span :
236
+ spans_to_be_logged .append (span )
241
237
242
- next_heartbeat_time = now + datetime .timedelta (
243
- milliseconds = self .heartbeat_interval_millis )
244
- self .ready_heartbeat_spans .put ((span_id , next_heartbeat_time ))
238
+ next_heartbeat_time = now + datetime .timedelta (
239
+ milliseconds = self .heartbeat_interval_millis )
240
+ self .ready_heartbeat_spans .put ((span_id , next_heartbeat_time ))
245
241
246
242
for span in spans_to_be_logged :
247
243
self .export_log (span , self .get_heartbeat_attributes ())
0 commit comments