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 779a0d6 commit 0895d23Copy full SHA for 0895d23
sentry_sdk/worker.py
@@ -192,8 +192,8 @@ def _target(self) -> None:
192
193
class AsyncWorker(Worker):
194
def __init__(self, queue_size: int = DEFAULT_QUEUE_SIZE) -> None:
195
- self._queue: asyncio.Queue = asyncio.Queue(queue_size)
196
- self._task: Optional[asyncio.Task] = None
+ self._queue: asyncio.Queue[Callable[[], Any]] = asyncio.Queue(queue_size)
+ 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
199
self._loop: Optional[asyncio.AbstractEventLoop] = None
0 commit comments