updatequeue len

Author: JqRrt

cozeloop/internal/trace/span_processor.py

@@ -16,7 +16,8 @@
     QUEUE_NAME_FILE, QUEUE_NAME_SPAN_RETRY, QUEUE_NAME_SPAN
 from cozeloop.internal.trace.span import Span
 
-DEFAULT_MAX_QUEUE_LENGTH = 2048
+DEFAULT_MAX_QUEUE_LENGTH = 1024
+DEFAULT_MAX_RETRY_QUEUE_LENGTH = 512
 DEFAULT_MAX_EXPORT_BATCH_LENGTH = 100
 DEFAULT_MAX_EXPORT_BATCH_BYTE_SIZE = 4 * 1024 * 1024  # 4MB
 MAX_RETRY_EXPORT_BATCH_LENGTH = 50
@@ -100,7 +101,7 @@ def __init__(
             BatchQueueManagerOptions(
                 queue_name=QUEUE_NAME_SPAN_RETRY,
                 batch_timeout=DEFAULT_SCHEDULE_DELAY,
-                max_queue_length=DEFAULT_MAX_QUEUE_LENGTH,
+                max_queue_length=DEFAULT_MAX_RETRY_QUEUE_LENGTH,
                 max_export_batch_length=MAX_RETRY_EXPORT_BATCH_LENGTH,
                 max_export_batch_byte_size=DEFAULT_MAX_EXPORT_BATCH_BYTE_SIZE,
                 export_func=self._new_export_spans_func(self.exporter, None, self.file_qm, finish_event_processor),