Skip to content

Commit 769ba30

Browse files
authored
internal: Ensure queue is at or over max size before dropping (#1399)
1 parent ed831e4 commit 769ba30

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

ddtrace/internal/writer.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -299,7 +299,7 @@ def put(self, item):
299299
# check qsize value.
300300
with self.mutex:
301301
qsize = self._qsize()
302-
if qsize != 0:
302+
if qsize >= self.maxsize:
303303
idx = random.randrange(0, qsize)
304304
self.queue[idx] = item
305305
log.warning("Writer queue is full has more than %d traces, some traces will be lost", self.maxsize)

0 commit comments

Comments
 (0)