We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b5eda0e commit 9e380b8Copy full SHA for 9e380b8
sentry_sdk/worker.py
@@ -191,7 +191,8 @@ def _target(self) -> None:
191
192
class AsyncWorker(Worker):
193
def __init__(self, queue_size: int = DEFAULT_QUEUE_SIZE) -> None:
194
- self._queue: asyncio.Queue[Any] = None
+ self._queue: asyncio.Queue[Any] = asyncio.Queue(maxsize=queue_size)
195
+ self._queue_size = queue_size
196
self._task: Optional[asyncio.Task[None]] = None
197
# Event loop needs to remain in the same process
198
self._task_for_pid: Optional[int] = None
0 commit comments