import weakref
from time import time
from typing import Any
+from collections import Counter
import pytest
from psycopg.pq import TransactionStatus
from psycopg.rows import class_row, Row, TupleRow
-from ..utils import assert_type, Counter, set_autocommit
+from ..utils import assert_type, set_autocommit
from ..acompat import Event, spawn, gather, sleep, skip_sync
from .test_pool_common import delay_connection
import weakref
from time import time
from typing import Any
+from collections import Counter
import pytest
from psycopg.pq import TransactionStatus
from psycopg.rows import class_row, Row, TupleRow
-from ..utils import assert_type, Counter, set_autocommit
+from ..utils import assert_type, set_autocommit
from ..acompat import AEvent, spawn, gather, asleep, skip_sync
from .test_pool_common_async import delay_connection
import re
import sys
import operator
-import collections
from typing import Callable
from contextlib import contextmanager
import pytest
-Counter = collections.Counter
-
if sys.version_info >= (3, 11):
import typing