import queue
import asyncio
import threading
-from typing import Any, Callable, Coroutine
+from typing import Any, Callable
+from collections.abc import Coroutine
from ._compat import TypeAlias, TypeVar
from __future__ import annotations
-from typing import Any, Sequence, TYPE_CHECKING
+from typing import Any, TYPE_CHECKING
from operator import attrgetter
+from collections.abc import Sequence
if TYPE_CHECKING:
from ._cursor_base import BaseCursor
from abc import ABC, abstractmethod
from types import TracebackType
-from typing import Any, Iterator, Sequence, TYPE_CHECKING
+from typing import Any, TYPE_CHECKING
+from collections.abc import Iterator, Sequence
from . import pq
from . import errors as e
from abc import ABC, abstractmethod
from types import TracebackType
-from typing import Any, AsyncIterator, Sequence, TYPE_CHECKING
+from typing import Any, TYPE_CHECKING
+from collections.abc import AsyncIterator, Sequence
from . import pq
from . import errors as e
from __future__ import annotations
from functools import partial
-from typing import Any, Generic, Iterable, NoReturn, Sequence
+from typing import Any, Generic, NoReturn
+from collections.abc import Iterable, Sequence
from typing import TYPE_CHECKING
from . import pq
import re
import warnings
from random import randint
-from typing import Any, DefaultDict, NamedTuple, Sequence, TYPE_CHECKING
+from typing import Any, DefaultDict, NamedTuple, TYPE_CHECKING
+from collections.abc import Sequence
from collections import defaultdict
try:
from __future__ import annotations
from enum import IntEnum, auto
-from typing import Any, Sequence, TYPE_CHECKING
+from typing import Any, TYPE_CHECKING
+from collections.abc import Sequence
from collections import OrderedDict
from . import pq
from __future__ import annotations
-from typing import Any, Sequence, DefaultDict, TYPE_CHECKING
+from typing import Any, DefaultDict, TYPE_CHECKING
+from collections.abc import Sequence
from collections import defaultdict
from . import pq
import re
from typing import Any, Callable, NamedTuple, TYPE_CHECKING
-from collections.abc import Mapping, Sequence
from functools import lru_cache
+from collections.abc import Mapping, Sequence
from . import pq
from . import errors as e
from __future__ import annotations
-from typing import Any, Iterator, overload, Sequence, TYPE_CHECKING
+from typing import Any, overload, TYPE_CHECKING
+from collections.abc import Iterator, Sequence
from . import sql
from . import errors as e
from __future__ import annotations
-from typing import Any, Callable, Generator, Mapping
-from typing import Protocol, Sequence, TYPE_CHECKING, Union
+from typing import Any, Callable, Protocol, TYPE_CHECKING, Union
+from collections.abc import Generator, Mapping, Sequence
from . import pq
from ._enums import PyFormat as PyFormat
import logging
from time import monotonic
from types import TracebackType
-from typing import Any, Generator, Iterator, cast, overload, TYPE_CHECKING
+from typing import Any, cast, overload, TYPE_CHECKING
from contextlib import contextmanager
+from collections.abc import Generator, Iterator
from . import pq
from . import errors as e
import logging
from time import monotonic
from types import TracebackType
-from typing import Any, AsyncGenerator, AsyncIterator, cast, overload, TYPE_CHECKING
+from typing import Any, cast, overload, TYPE_CHECKING
from contextlib import asynccontextmanager
+from collections.abc import AsyncGenerator, AsyncIterator
from . import pq
from . import errors as e
from __future__ import annotations
from types import TracebackType
-from typing import Any, Iterator, Iterable, TYPE_CHECKING, overload
+from typing import Any, TYPE_CHECKING, overload
from contextlib import contextmanager
+from collections.abc import Iterator, Iterable
from . import pq
from . import errors as e
from __future__ import annotations
from types import TracebackType
-from typing import Any, AsyncIterator, Iterable, TYPE_CHECKING, overload
+from typing import Any, TYPE_CHECKING, overload
from contextlib import asynccontextmanager
+from collections.abc import AsyncIterator, Iterable
from . import pq
from . import errors as e
import time
import datetime as dt
from math import floor
-from typing import Any, Sequence
+from typing import Any
+from collections.abc import Sequence
from . import _oids
from .abc import AdaptContext, Buffer
from __future__ import annotations
from dataclasses import dataclass, field, fields
-from typing import Any, Callable, NoReturn, Sequence, TYPE_CHECKING
+from typing import Any, Callable, NoReturn, TYPE_CHECKING
from asyncio import CancelledError
+from collections.abc import Sequence
from .pq.abc import PGconn, PGresult
from .pq._enums import ConnStatus, DiagnosticField, PipelineStatus, TransactionStatus
from __future__ import annotations
-from typing import Any, Callable, Protocol, Sequence, TYPE_CHECKING, Union
+from typing import Any, Callable, Protocol, TYPE_CHECKING, Union
+from collections.abc import Sequence
from ._enums import Format, Trace
from .._compat import Self, TypeAlias
from ctypes import Array, POINTER, cast, string_at, create_string_buffer, byref
from ctypes import addressof, c_char_p, c_int, c_size_t, c_ulong, c_void_p, py_object
-from typing import Any, Callable, Sequence
-from typing import cast as t_cast, TYPE_CHECKING
+from typing import Any, Callable, cast as t_cast, TYPE_CHECKING
+from collections.abc import Sequence
from .. import errors as e
from .._encodings import pg2pyenc
from __future__ import annotations
import functools
-from typing import Any, Callable, NamedTuple, NoReturn
-from typing import TYPE_CHECKING, Protocol, Sequence
+from typing import Any, Callable, NamedTuple, NoReturn, Protocol, TYPE_CHECKING
from collections import namedtuple
+from collections.abc import Sequence
from . import pq
from . import errors as e
from __future__ import annotations
-from typing import Any, AsyncIterator, Iterable, Iterator, TYPE_CHECKING, overload
+from typing import Any, overload, TYPE_CHECKING
from warnings import warn
+from collections.abc import AsyncIterator, Iterable, Iterator
from . import pq
from . import sql
import codecs
import string
from abc import ABC, abstractmethod
-from typing import Any, Iterator, Iterable, Sequence
+from typing import Any
+from collections.abc import Iterator, Iterable, Sequence
from .pq import Escaping
from .abc import AdaptContext
import logging
from types import TracebackType
-from typing import Any, Generic, Iterator, TYPE_CHECKING
+from typing import Any, Generic, TYPE_CHECKING
+from collections.abc import Iterator
from . import pq
from . import sql
import re
import struct
+from typing import Any, Callable, cast, NamedTuple, TYPE_CHECKING
from collections import namedtuple
-from typing import Any, Callable, cast, Iterator
-from typing import NamedTuple, Sequence, TYPE_CHECKING
+from collections.abc import Iterator, Sequence
from .. import pq
from .. import abc
from __future__ import annotations
from enum import Enum
-from typing import Any, Generic, Mapping, Sequence, cast, TYPE_CHECKING
+from typing import Any, Generic, cast, TYPE_CHECKING
+from collections.abc import Mapping, Sequence
from .. import sql
from .. import postgres
from __future__ import annotations
from decimal import Decimal
-from typing import Any, Generic, Iterable, MutableSequence, overload, TYPE_CHECKING
+from typing import Any, Generic, overload, TYPE_CHECKING
from datetime import date, datetime
+from collections.abc import Iterable, MutableSequence
from .. import sql
from .. import _oids
import asyncio
import logging
import threading
-from typing import Any, Callable, Coroutine
+from typing import Any, Callable
+from collections.abc import Coroutine
from ._compat import TypeAlias, TypeVar
from __future__ import annotations
-from typing import Awaitable, Callable, TYPE_CHECKING, Union
+from typing import Callable, TYPE_CHECKING, Union
+from collections.abc import Awaitable
from ._compat import TypeAlias, TypeVar
from abc import ABC, abstractmethod
from time import monotonic
from types import TracebackType
-from typing import Any, Iterator, cast, Generic
+from typing import Any, cast, Generic
+from collections.abc import Iterator
from weakref import ref
from contextlib import contextmanager
from abc import ABC, abstractmethod
from time import monotonic
from types import TracebackType
-from typing import Any, AsyncIterator, cast, Generic
+from typing import Any, cast, Generic
+from collections.abc import AsyncIterator
from weakref import ref
from contextlib import asynccontextmanager
import os
import sys
import ctypes
-from typing import Iterator, NamedTuple
+from typing import NamedTuple
from tempfile import TemporaryFile
+from collections.abc import Iterator
import pytest
import weakref
from functools import partial
from select import select
-from typing import Iterator, TYPE_CHECKING
+from typing import TYPE_CHECKING
+from collections.abc import Iterator
import pytest
import asyncio
import logging
from enum import Enum
-from typing import Any, Generator
+from typing import Any
+from collections.abc import Generator
from argparse import ArgumentParser, Namespace
from contextlib import contextmanager
from concurrent.futures import ThreadPoolExecutor
@contextmanager
-def time_log(message: str) -> Generator[None, None, None]:
+def time_log(message: str) -> Generator[None]:
start = time.monotonic()
yield
end = time.monotonic()
import logging
from contextlib import contextmanager
from functools import partial
-from typing import Any, Iterator, Sequence
+from typing import Any
+from collections.abc import Iterator, Sequence
from psycopg import AsyncConnection, Connection
from psycopg import pq, waiting
from __future__ import annotations
from dataclasses import dataclass
-from typing import Any, Callable, Sequence
+from typing import Any, Callable
+from collections.abc import Sequence
from psycopg import Connection, Cursor, ServerCursor, connect, rows
from psycopg import AsyncConnection, AsyncCursor, AsyncServerCursor