AssertionError: should have no new active queries
assert not [{'application_name': '', 'backend_start': '2024-02-01 11:25:37.141233+00:00', 'client_addr': '172.21.0.6', 'client_hostname': None, ...}]
self = <dl_core_tests.db.compeng.test_pg_op_exec_adapter.TestAiopgOpRunner object at 0x7fec22f38a90>
pg_adapter = AiopgExecAdapter(_cache_options_builder=CompengOptionsBuilder(default_ttl_config=CacheTTLConfig(ttl_sec_direct=60, ttl...PostgreSQLTypeTransformer object at 0x7fec2228ec80>, _conn=<aiopg.sa.connection.SAConnection object at 0x7fec222b5de0>)

    @pytest.mark.asyncio
    async def test_insert_fetch(self, pg_adapter: PostgreSQLExecAdapterAsync):
        queries_before = await get_active_queries(pg_adapter)
    
        table_name = f"table_{uuid.uuid4()}"
        names = ["int_value", "str_value", "bool_value"]
        user_types = [UserDataType.integer, UserDataType.string, UserDataType.boolean]
    
        raw_data = [
            # 5 chunks X 1000 rows
            [(i * 100, f"str_{i}", bool(i % 2)) for i in range(j * 1000, j * 1000 + 1000)]
            for j in range(5)
        ]
        data = AsyncChunked.from_chunked_iterable(raw_data)
        await pg_adapter.create_table(table_name=table_name, names=names, user_types=user_types)
        assert await self.table_exists(pg_adapter=pg_adapter, table_name=table_name)
    
        await pg_adapter.insert_data_into_table(table_name=table_name, names=names, user_types=user_types, data=data)
        ctx = OpExecutionContext(processing_id="", streams=[], operations=[])
        fetched_data = await pg_adapter.fetch_data_from_select(
            query=f'SELECT {", ".join(names)} FROM "{table_name}" ORDER BY int_value',
            user_types=user_types,
            query_id=make_id(),
            ctx=ctx,
        )
        fetched_as_lists = [list(row) for row in await fetched_data.all()]
        original_as_lists = [list(row) for row in await AsyncChunked.from_chunked_iterable(raw_data).all()]
        assert fetched_as_lists == original_as_lists
    
        queries_after = await get_active_queries(pg_adapter)
        new_queries = [q for q in queries_after if q not in queries_before]
>       assert not new_queries, "should have no new active queries"
E       AssertionError: should have no new active queries
E       assert not [{'application_name': '', 'backend_start': '2024-02-01 11:25:37.141233+00:00', 'client_addr': '172.21.0.6', 'client_hostname': None, ...}]

db/compeng/test_pg_op_exec_adapter.py:124: AssertionError

failed on setup with "Exception: ('Timed out waiting for WSGI to come up at http://127.0.0.1:59445/ping', {'last_error': ConnectTimeout(MaxRetryError("HTTPConnectionPool(host='127.0.0.1', port=59445): Max retries exceeded with url: /ping (Caused by ConnectTimeoutError(<urllib3.connection.HTTPConnection object at 0x7ff3f40c4280>, 'Connection to 127.0.0.1 timed out. (connect timeout=0.1)'))")), 'last_resp': None, 'last_resp_text': None})"
request = <FixtureRequest for <Function test_parameter_in_formula[-1-HTTPStatus.BAD_REQUEST]>>

    def fill(request):
        item = request._pyfuncitem
        fixturenames = getattr(item, "fixturenames", None)
        if fixturenames is None:
            fixturenames = request.fixturenames
    
        if hasattr(item, 'callspec'):
            for param, val in sorted_by_dependency(item.callspec.params, fixturenames):
                if val is not None and is_lazy_fixture(val):
                    item.callspec.params[param] = request.getfixturevalue(val.name)
                elif param not in item.funcargs:
>                   item.funcargs[param] = request.getfixturevalue(param)

/venv/lib/python3.10/site-packages/pytest_lazyfixture.py:37: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/venv/lib/python3.10/site-packages/dl_api_lib_testing/base.py:90: in rqe_config_subprocess
    with RQEConfigurationMaker(bi_test_config=bi_test_config).rqe_config_subprocess_cm() as rqe_config:
/usr/lib/python3.10/contextlib.py:135: in __enter__
    return next(self.gen)
/venv/lib/python3.10/site-packages/dl_api_lib_testing/app.py:93: in rqe_config_subprocess_cm
    with (
/usr/lib/python3.10/contextlib.py:135: in __enter__
    return next(self.gen)
/venv/lib/python3.10/site-packages/dl_api_lib_testing/app.py:73: in sync_rqe_netloc_subprocess_cm
    with WSGIRunner(
/venv/lib/python3.10/site-packages/dl_core_testing/fixture_server_runner.py:213: in __enter__
    self.run()  # type: ignore  # TODO: fix
/venv/lib/python3.10/site-packages/dl_core_testing/fixture_server_runner.py:154: in run
    self.wait_for_up()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = WSGIRunner(_module='dl_core.bin.query_executor_sync', _callable='app', _ping_path='/ping', _bind_port=59445, _bind_add...IST': 'clickhouse,postgresql'}, _proc=<Popen: returncode: None args: ['uwsgi', '--die-on-term', '--master', '--mod...>)

    def wait_for_up(self) -> None:
        url = f"http://{self._bind_addr}:{self._bind_port}/{self._ping_path.lstrip('/')}"
        start_time = time.monotonic()
        max_time = start_time + self._wait_time
        last_error = None
        resp = None
    
        while True:
            if self._proc.returncode is not None:
                # TODO FIX: add output
                raise Exception("WSGI process down")
    
            next_attempt_time = time.monotonic() + self._poll_time
            try:
                resp = requests.get(url, timeout=self._poll_time)
            except Exception as err:
                last_error = err
            else:
                if resp.ok:
                    LOGGER.debug("WSGI app ok on url: %s", url)
                    break
            LOGGER.debug("Still waiting for WSGI app: err=%r / resp=%r", last_error, resp)
            now = time.monotonic()
            if now > max_time:
>               raise Exception(
                    f"Timed out waiting for WSGI to come up at {url}",
                    dict(last_error=last_error, last_resp=resp, last_resp_text=resp.text if resp is not None else None),
                )
E               Exception: ('Timed out waiting for WSGI to come up at http://127.0.0.1:59445/ping', {'last_error': ConnectTimeout(MaxRetryError("HTTPConnectionPool(host='127.0.0.1', port=59445): Max retries exceeded with url: /ping (Caused by ConnectTimeoutError(<urllib3.connection.HTTPConnection object at 0x7ff3f40c4280>, 'Connection to 127.0.0.1 timed out. (connect timeout=0.1)'))")), 'last_resp': None, 'last_resp_text': None})

/venv/lib/python3.10/site-packages/dl_core_testing/fixture_server_runner.py:142: Exception