fix

Author: JqRrt

cozeloop/internal/trace/queue_manager.py

@@ -109,22 +109,20 @@ def _drain_queue(self):
         self._do_export_batch()
 
     def _do_export(self):
-        logger.debug(
-            f"{self.options.queue_name} queue _do_export, len: {len(self.batch)}")
         with self.batch_lock:
             while not self.queue.empty():
                 item = self.queue.get()
                 self.batch.append(item)
                 if len(self.batch) == self.options.max_export_batch_length:
                     break
-        logger.debug(
-            f"{self.options.queue_name} queue _do_export_end, len: {len(self.batch)}")
         self._do_export_batch()
 
     def _do_export_batch(self):
         with self.batch_lock:
             if self.batch:
                 if self.export_func:
+                    logger.debug(
+                        f"{self.options.queue_name} queue _do_export, len: {len(self.batch)}")
                     self.export_func({}, self.batch)
                 self.batch = []
                 with self.size_lock: