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 0f63d24 commit 2430e2eCopy full SHA for 2430e2e
sentry_sdk/worker.py
@@ -176,8 +176,8 @@ def _target(self) -> None:
176
177
class AsyncWorker(Worker):
178
def __init__(self, queue_size: int = DEFAULT_QUEUE_SIZE) -> None:
179
- self._queue: asyncio.Queue = asyncio.Queue(queue_size)
180
- self._task: Optional[asyncio.Task] = None
+ self._queue: asyncio.Queue[Callable[[], Any]] = asyncio.Queue(queue_size)
+ self._task: Optional[asyncio.Task[None]] = None
181
# Event loop needs to remain in the same process
182
self._task_for_pid: Optional[int] = None
183
self._loop: Optional[asyncio.AbstractEventLoop] = None
0 commit comments