from typing import Callable, cast, Optional, Tuple
from .abc import Buffer
-from .compat import Protocol
+from ._compat import Protocol
PackInt = Callable[[int], bytes]
UnpackInt = Callable[[bytes], Tuple[int]]
from typing import Dict, Optional, Union
from datetime import timezone, tzinfo
-from .compat import ZoneInfo
from .pq.abc import PGconn
+from ._compat import ZoneInfo
logger = logging.getLogger("psycopg")
from . import pq
from ._enums import PyFormat as PyFormat
-from .compat import Protocol
+from ._compat import Protocol
if TYPE_CHECKING:
from .sql import Composable
from .abc import Params, PQGen, PQGenConn, Query, RV
from .rows import Row, AsyncRowFactory, tuple_row, TupleRow
from ._enums import IsolationLevel
-from .compat import asynccontextmanager
+from ._compat import asynccontextmanager
from .conninfo import make_conninfo, conninfo_to_dict
from .connection import BaseConnection, CursorRow, Notify
from .generators import notifies
from .pq import ExecStatus
from .abc import ConnectionType, PQGen, Transformer
from .adapt import PyFormat
-from .compat import create_task
+from ._compat import create_task
from ._cmodule import _psycopg
from .generators import copy_from, copy_to, copy_end
from .abc import Query, Params
from .copy import AsyncCopy
from .rows import Row, RowMaker, AsyncRowFactory
-from .compat import asynccontextmanager
from .cursor import BaseCursor, AnyCursor
+from ._compat import asynccontextmanager
if TYPE_CHECKING:
from .connection_async import AsyncConnection
from typing import TYPE_CHECKING
from ._enums import Format
-from ..compat import Protocol
+from .._compat import Protocol
if TYPE_CHECKING:
from .misc import PGnotify, ConninfoOption, PGresAttDesc
from collections import namedtuple
from . import errors as e
-from .compat import Protocol
+from ._compat import Protocol
if TYPE_CHECKING:
from .cursor import BaseCursor, Cursor
from psycopg_c._psycopg cimport endian
from psycopg import errors as e
-from psycopg.compat import ZoneInfo
+from psycopg._compat import ZoneInfo
# Initialise the datetime C API
from psycopg import errors as e
from psycopg.pq import TransactionStatus
-from psycopg.compat import Task, asynccontextmanager, create_task
+from psycopg._compat import Task, asynccontextmanager, create_task
from psycopg.connection_async import AsyncConnection
from .base import ConnectionAttempt, BasePool
import psycopg
from psycopg import sql
from psycopg.adapt import PyFormat
-from psycopg.compat import asynccontextmanager
+from psycopg._compat import asynccontextmanager
from psycopg.types.range import Range
from psycopg.types.numeric import Int4, Int8
import psycopg
import psycopg_pool as pool
from psycopg.pq import TransactionStatus
-from psycopg.compat import create_task
+from psycopg._compat import create_task
pytestmark = [
pytest.mark.asyncio,
import pytest
-from psycopg.compat import create_task
+from psycopg._compat import create_task
from psycopg_pool.sched import AsyncScheduler
pytestmark = [pytest.mark.asyncio, pytest.mark.timing]
from asyncio.queues import Queue
import psycopg
-from psycopg.compat import create_task
+from psycopg._compat import create_task
pytestmark = pytest.mark.asyncio