diff options
| author | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-04-26 01:55:33 +0300 |
|---|---|---|
| committer | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-07-19 00:48:06 +0300 |
| commit | e3158fdf59a7c92a9449a566a2b746a4024e582f (patch) | |
| tree | 7ae5c528432034cea0b70c01fd0571969094734a /src | |
| parent | 92219f0f86366583faa709e41b4e69453dcf2390 (diff) | |
| download | apscheduler-e3158fdf59a7c92a9449a566a2b746a4024e582f.tar.gz | |
Fixed return type annotation of AsyncpgEventBroker.__aenter__()
Diffstat (limited to 'src')
| -rw-r--r-- | src/apscheduler/eventbrokers/asyncpg.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/apscheduler/eventbrokers/asyncpg.py b/src/apscheduler/eventbrokers/asyncpg.py index cc485db..d97c229 100644 --- a/src/apscheduler/eventbrokers/asyncpg.py +++ b/src/apscheduler/eventbrokers/asyncpg.py @@ -47,7 +47,7 @@ class AsyncpgEventBroker(LocalAsyncEventBroker, DistributedEventBrokerMixin): return cls(connection_factory) - async def __aenter__(self) -> LocalAsyncEventBroker: + async def __aenter__(self) -> AsyncpgEventBroker: await super().__aenter__() await self._task_group.start(self._listen_notifications) self._exit_stack.callback(self._task_group.cancel_scope.cancel) |