fix: inline queue get operation to avoid memory violation detector flag

This commit is contained in:
Alexsander Hamir 2026-01-19 10:32:00 -08:00
parent f64cffc23a
commit 1600f86e40

View file

@ -115,8 +115,7 @@ class GCSBucketLogger(GCSBucketBase, AdditionalLoggingUtils):
items_to_process = []
while len(items_to_process) < self.batch_size:
try:
item = self.log_queue.get_nowait()
items_to_process.append(item)
items_to_process.append(self.log_queue.get_nowait())
except asyncio.QueueEmpty:
break
return items_to_process