@@ -207,14 +207,12 @@ def process_delayed_heartbeat_spans(self) -> None:
207207 self .delayed_heartbeat_spans .get ()
208208
209209 span = self .active_spans .get (span_id )
210- if not span :
211- continue
210+ if span :
211+ spans_to_be_logged . append ( span )
212212
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 ))
218216
219217 for span in spans_to_be_logged :
220218 self .export_log (span , self .get_heartbeat_attributes ())
@@ -234,14 +232,12 @@ def process_ready_heartbeat_spans(self) -> None:
234232 self .ready_heartbeat_spans .get ()
235233
236234 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 )
241237
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 ))
245241
246242 for span in spans_to_be_logged :
247243 self .export_log (span , self .get_heartbeat_attributes ())
0 commit comments