from .. import errors as e
from ..pq import TransactionStatus
from ..connection import AsyncConnection
-from ..utils.compat import asynccontextmanager, create_task
+from ..utils.compat import Task, asynccontextmanager, create_task
from .base import ConnectionAttempt, BasePool
from .sched import AsyncScheduler
self._sched = AsyncScheduler()
self._tasks: "asyncio.Queue[MaintenanceTask]" = asyncio.Queue()
- self._workers: "List[asyncio.Task[None]]" = []
+ self._workers: List[Task[None]] = []
super().__init__(conninfo, **kwargs)
if sys.version_info >= (3, 8):
create_task = asyncio.create_task
+ Task = asyncio.Task
elif sys.version_info >= (3, 7):
) -> "asyncio.Future[T]":
return asyncio.create_task(coro)
+ Task = asyncio.Future
else:
) -> "asyncio.Future[T]":
return asyncio.ensure_future(coro)
+ Task = asyncio.Future
__all__ = ["asynccontextmanager", "get_running_loop", "create_task"]