Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

⬆️ Upgrade to python 3.13 #1133

Merged
merged 8 commits into from
Jan 17, 2025
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
⬆️ Update lock files (using no-cache)
ff137 committed Jan 17, 2025
commit 783ba90fea7021f387aceb641adefc1b541cd77f
Loading

Unchanged files with check annotations Beta

import asyncio

Check failure on line 1 in app/tests/e2e/issuer/test_save_exchange_record.py

GitHub Actions / JUnit Test Report

test_save_exchange_record.test_issue_credential_with_save_exchange_record[clean-clean-clean-clean-clean-None]

failed on setup with "app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server."
Raw output
anyio_backend = 'asyncio'
request = <SubRequest 'faber_and_alice_connection' for <Function test_issue_credential_with_save_exchange_record[clean-clean-clean-clean-clean-None]>>
args = ()
kwargs = {'alice_member_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f60789d7790>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f60789ec7d0>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7f6080f79620>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7f60800530e0>

    def wrapper(
        *args: Any, anyio_backend: Any, request: SubRequest, **kwargs: Any
    ) -> Any:
        # Rebind any fixture methods to the request instance
        if (
            request.instance
            and ismethod(func)
            and type(func.__self__) is type(request.instance)
        ):
            local_func = func.__func__.__get__(request.instance)
        else:
            local_func = func
    
        backend_name, backend_options = extract_backend_and_options(anyio_backend)
        if has_backend_arg:
            kwargs["anyio_backend"] = anyio_backend
    
        if has_request_arg:
            kwargs["request"] = request
    
        with get_runner(backend_name, backend_options) as runner:
            if isasyncgenfunction(local_func):
                yield from runner.run_asyncgen_fixture(local_func, kwargs)
            else:
>               yield runner.run_fixture(local_func, kwargs)

/usr/local/lib/python3.13/site-packages/anyio/pytest_plugin.py:100: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2256: in run_fixture
    retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.13/asyncio/base_events.py:720: in run_until_complete
    return future.result()
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2226: in _call_in_runner_task
    return await future
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2193: in _run_tests_and_fixtures
    retval = await coro
app/tests/fixtures/member_connections.py:46: in faber_and_alice_connection
    bob_alice_connection = await create_connection_by_test_mode(
app/tests/util/connections.py:202: in create_connection_by_test_mode
    return await create_did_exchange(
app/tests/util/connections.py:332: in create_did_exchange
    bob_connection = await check_webhook_state(
app/tests/util/webhooks.py:59: in check_webhook_state
    event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <app.tests.util.sse_listener.SseListener object at 0x7f60795f1550>
field = 'their_did', field_id = '8vU3HKuQ1aPEKFDHUvsrTg'
desired_state = 'request-received', timeout = Timeout(timeout=45)
look_back = 15

    async def wait_for_event(
        self,
        field,
        field_id,
        desired_state,
        timeout: int = DEFAULT_LISTENER_TIMEOUT,
        look_back: int = 15,
    ) -> Dict[str, Any]:
        """
        Start listening for SSE events. When an event is received that matches the specified parameters.
        """
        url = f"{waypoint_base_url}/{self.wallet_id}/{self.topic}/{field}/{field_id}/{desired_state}"
        params = {"look_back": look_back}
    
        timeout = Timeout(timeout)
        async with RichAsyncClient(timeout=timeout) as client:
            async with client.stream("GET", url, params=params) as response:
                async for line in response.aiter_lines():
                    if line.startswith("data: "):
                        data = json.loads(line[6:])
                        return data["payload"]
                    elif line == "" or line.startswith(": ping"):
                        pass  # ignore newlines and pings
                    else:
                        logger.warning("Unexpected SSE line: {}", line)
    
>       raise SseListenerTimeout("Requested filtered event was not returned by server.")
E       app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server.

app/tests/util/sse_listener.py:58: SseListenerTimeout

Check failure on line 1 in app/tests/e2e/issuer/test_save_exchange_record.py

GitHub Actions / JUnit Test Report

test_save_exchange_record.test_issue_credential_with_save_exchange_record[clean-clean-clean-clean-clean-False]

failed on setup with "app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server."
Raw output
anyio_backend = 'asyncio'
request = <SubRequest 'faber_and_alice_connection' for <Function test_issue_credential_with_save_exchange_record[clean-clean-clean-clean-clean-False]>>
args = ()
kwargs = {'alice_member_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f6078d26350>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f60789ec7d0>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7f6080f79620>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7f60800530e0>

    def wrapper(
        *args: Any, anyio_backend: Any, request: SubRequest, **kwargs: Any
    ) -> Any:
        # Rebind any fixture methods to the request instance
        if (
            request.instance
            and ismethod(func)
            and type(func.__self__) is type(request.instance)
        ):
            local_func = func.__func__.__get__(request.instance)
        else:
            local_func = func
    
        backend_name, backend_options = extract_backend_and_options(anyio_backend)
        if has_backend_arg:
            kwargs["anyio_backend"] = anyio_backend
    
        if has_request_arg:
            kwargs["request"] = request
    
        with get_runner(backend_name, backend_options) as runner:
            if isasyncgenfunction(local_func):
                yield from runner.run_asyncgen_fixture(local_func, kwargs)
            else:
>               yield runner.run_fixture(local_func, kwargs)

/usr/local/lib/python3.13/site-packages/anyio/pytest_plugin.py:100: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2256: in run_fixture
    retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.13/asyncio/base_events.py:720: in run_until_complete
    return future.result()
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2226: in _call_in_runner_task
    return await future
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2193: in _run_tests_and_fixtures
    retval = await coro
app/tests/fixtures/member_connections.py:46: in faber_and_alice_connection
    bob_alice_connection = await create_connection_by_test_mode(
app/tests/util/connections.py:202: in create_connection_by_test_mode
    return await create_did_exchange(
app/tests/util/connections.py:332: in create_did_exchange
    bob_connection = await check_webhook_state(
app/tests/util/webhooks.py:59: in check_webhook_state
    event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <app.tests.util.sse_listener.SseListener object at 0x7f60789ed590>
field = 'their_did', field_id = '8b2p1oGFRJPb7MJ4SXEDos'
desired_state = 'request-received', timeout = Timeout(timeout=45)
look_back = 15

    async def wait_for_event(
        self,
        field,
        field_id,
        desired_state,
        timeout: int = DEFAULT_LISTENER_TIMEOUT,
        look_back: int = 15,
    ) -> Dict[str, Any]:
        """
        Start listening for SSE events. When an event is received that matches the specified parameters.
        """
        url = f"{waypoint_base_url}/{self.wallet_id}/{self.topic}/{field}/{field_id}/{desired_state}"
        params = {"look_back": look_back}
    
        timeout = Timeout(timeout)
        async with RichAsyncClient(timeout=timeout) as client:
            async with client.stream("GET", url, params=params) as response:
                async for line in response.aiter_lines():
                    if line.startswith("data: "):
                        data = json.loads(line[6:])
                        return data["payload"]
                    elif line == "" or line.startswith(": ping"):
                        pass  # ignore newlines and pings
                    else:
                        logger.warning("Unexpected SSE line: {}", line)
    
>       raise SseListenerTimeout("Requested filtered event was not returned by server.")
E       app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server.

app/tests/util/sse_listener.py:58: SseListenerTimeout

Check failure on line 1 in app/tests/e2e/issuer/test_save_exchange_record.py

GitHub Actions / JUnit Test Report

test_save_exchange_record.test_issue_credential_with_save_exchange_record[clean-clean-clean-clean-clean-True]

failed on setup with "app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server."
Raw output
anyio_backend = 'asyncio'
request = <SubRequest 'faber_and_alice_connection' for <Function test_issue_credential_with_save_exchange_record[clean-clean-clean-clean-clean-True]>>
args = ()
kwargs = {'alice_member_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f6078de98b0>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f60789ec7d0>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7f6080f79620>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7f60800530e0>

    def wrapper(
        *args: Any, anyio_backend: Any, request: SubRequest, **kwargs: Any
    ) -> Any:
        # Rebind any fixture methods to the request instance
        if (
            request.instance
            and ismethod(func)
            and type(func.__self__) is type(request.instance)
        ):
            local_func = func.__func__.__get__(request.instance)
        else:
            local_func = func
    
        backend_name, backend_options = extract_backend_and_options(anyio_backend)
        if has_backend_arg:
            kwargs["anyio_backend"] = anyio_backend
    
        if has_request_arg:
            kwargs["request"] = request
    
        with get_runner(backend_name, backend_options) as runner:
            if isasyncgenfunction(local_func):
                yield from runner.run_asyncgen_fixture(local_func, kwargs)
            else:
>               yield runner.run_fixture(local_func, kwargs)

/usr/local/lib/python3.13/site-packages/anyio/pytest_plugin.py:100: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2256: in run_fixture
    retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.13/asyncio/base_events.py:720: in run_until_complete
    return future.result()
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2226: in _call_in_runner_task
    return await future
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2193: in _run_tests_and_fixtures
    retval = await coro
app/tests/fixtures/member_connections.py:46: in faber_and_alice_connection
    bob_alice_connection = await create_connection_by_test_mode(
app/tests/util/connections.py:202: in create_connection_by_test_mode
    return await create_did_exchange(
app/tests/util/connections.py:332: in create_did_exchange
    bob_connection = await check_webhook_state(
app/tests/util/webhooks.py:59: in check_webhook_state
    event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <app.tests.util.sse_listener.SseListener object at 0x7f60789eefd0>
field = 'their_did', field_id = 'FcqerRUuttjY3fypqjmo8z'
desired_state = 'request-received', timeout = Timeout(timeout=45)
look_back = 15

    async def wait_for_event(
        self,
        field,
        field_id,
        desired_state,
        timeout: int = DEFAULT_LISTENER_TIMEOUT,
        look_back: int = 15,
    ) -> Dict[str, Any]:
        """
        Start listening for SSE events. When an event is received that matches the specified parameters.
        """
        url = f"{waypoint_base_url}/{self.wallet_id}/{self.topic}/{field}/{field_id}/{desired_state}"
        params = {"look_back": look_back}
    
        timeout = Timeout(timeout)
        async with RichAsyncClient(timeout=timeout) as client:
            async with client.stream("GET", url, params=params) as response:
                async for line in response.aiter_lines():
                    if line.startswith("data: "):
                        data = json.loads(line[6:])
                        return data["payload"]
                    elif line == "" or line.startswith(": ping"):
                        pass  # ignore newlines and pings
                    else:
                        logger.warning("Unexpected SSE line: {}", line)
    
>       raise SseListenerTimeout("Requested filtered event was not returned by server.")
E       app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server.

app/tests/util/sse_listener.py:58: SseListenerTimeout

Check failure on line 1 in app/tests/e2e/issuer/test_save_exchange_record.py

GitHub Actions / JUnit Test Report

test_save_exchange_record.test_request_credential_with_save_exchange_record[clean-clean-clean-clean-clean-None]

failed on setup with "app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server."
Raw output
anyio_backend = 'asyncio'
request = <SubRequest 'faber_and_alice_connection' for <Function test_request_credential_with_save_exchange_record[clean-clean-clean-clean-clean-None]>>
args = ()
kwargs = {'alice_member_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f6078de9040>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f60789ec7d0>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7f6080f79620>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7f60800530e0>

    def wrapper(
        *args: Any, anyio_backend: Any, request: SubRequest, **kwargs: Any
    ) -> Any:
        # Rebind any fixture methods to the request instance
        if (
            request.instance
            and ismethod(func)
            and type(func.__self__) is type(request.instance)
        ):
            local_func = func.__func__.__get__(request.instance)
        else:
            local_func = func
    
        backend_name, backend_options = extract_backend_and_options(anyio_backend)
        if has_backend_arg:
            kwargs["anyio_backend"] = anyio_backend
    
        if has_request_arg:
            kwargs["request"] = request
    
        with get_runner(backend_name, backend_options) as runner:
            if isasyncgenfunction(local_func):
                yield from runner.run_asyncgen_fixture(local_func, kwargs)
            else:
>               yield runner.run_fixture(local_func, kwargs)

/usr/local/lib/python3.13/site-packages/anyio/pytest_plugin.py:100: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2256: in run_fixture
    retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.13/asyncio/base_events.py:720: in run_until_complete
    return future.result()
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2226: in _call_in_runner_task
    return await future
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2193: in _run_tests_and_fixtures
    retval = await coro
app/tests/fixtures/member_connections.py:46: in faber_and_alice_connection
    bob_alice_connection = await create_connection_by_test_mode(
app/tests/util/connections.py:202: in create_connection_by_test_mode
    return await create_did_exchange(
app/tests/util/connections.py:332: in create_did_exchange
    bob_connection = await check_webhook_state(
app/tests/util/webhooks.py:59: in check_webhook_state
    event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <app.tests.util.sse_listener.SseListener object at 0x7f607855b360>
field = 'their_did', field_id = 'Ce3s9Mnb19i4ba5V2p1sur'
desired_state = 'request-received', timeout = Timeout(timeout=45)
look_back = 15

    async def wait_for_event(
        self,
        field,
        field_id,
        desired_state,
        timeout: int = DEFAULT_LISTENER_TIMEOUT,
        look_back: int = 15,
    ) -> Dict[str, Any]:
        """
        Start listening for SSE events. When an event is received that matches the specified parameters.
        """
        url = f"{waypoint_base_url}/{self.wallet_id}/{self.topic}/{field}/{field_id}/{desired_state}"
        params = {"look_back": look_back}
    
        timeout = Timeout(timeout)
        async with RichAsyncClient(timeout=timeout) as client:
            async with client.stream("GET", url, params=params) as response:
                async for line in response.aiter_lines():
                    if line.startswith("data: "):
                        data = json.loads(line[6:])
                        return data["payload"]
                    elif line == "" or line.startswith(": ping"):
                        pass  # ignore newlines and pings
                    else:
                        logger.warning("Unexpected SSE line: {}", line)
    
>       raise SseListenerTimeout("Requested filtered event was not returned by server.")
E       app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server.

app/tests/util/sse_listener.py:58: SseListenerTimeout

Check failure on line 1 in app/tests/e2e/issuer/test_save_exchange_record.py

GitHub Actions / JUnit Test Report

test_save_exchange_record.test_request_credential_with_save_exchange_record[clean-clean-clean-clean-clean-False]

failed on setup with "app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server."
Raw output
anyio_backend = 'asyncio'
request = <SubRequest 'faber_and_alice_connection' for <Function test_request_credential_with_save_exchange_record[clean-clean-clean-clean-clean-False]>>
args = ()
kwargs = {'alice_member_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f6078de8e60>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f60789ec7d0>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7f6080f79620>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7f60800530e0>

    def wrapper(
        *args: Any, anyio_backend: Any, request: SubRequest, **kwargs: Any
    ) -> Any:
        # Rebind any fixture methods to the request instance
        if (
            request.instance
            and ismethod(func)
            and type(func.__self__) is type(request.instance)
        ):
            local_func = func.__func__.__get__(request.instance)
        else:
            local_func = func
    
        backend_name, backend_options = extract_backend_and_options(anyio_backend)
        if has_backend_arg:
            kwargs["anyio_backend"] = anyio_backend
    
        if has_request_arg:
            kwargs["request"] = request
    
        with get_runner(backend_name, backend_options) as runner:
            if isasyncgenfunction(local_func):
                yield from runner.run_asyncgen_fixture(local_func, kwargs)
            else:
>               yield runner.run_fixture(local_func, kwargs)

/usr/local/lib/python3.13/site-packages/anyio/pytest_plugin.py:100: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2256: in run_fixture
    retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.13/asyncio/base_events.py:720: in run_until_complete
    return future.result()
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2226: in _call_in_runner_task
    return await future
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2193: in _run_tests_and_fixtures
    retval = await coro
app/tests/fixtures/member_connections.py:46: in faber_and_alice_connection
    bob_alice_connection = await create_connection_by_test_mode(
app/tests/util/connections.py:202: in create_connection_by_test_mode
    return await create_did_exchange(
app/tests/util/connections.py:332: in create_did_exchange
    bob_connection = await check_webhook_state(
app/tests/util/webhooks.py:59: in check_webhook_state
    event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <app.tests.util.sse_listener.SseListener object at 0x7f607855a9e0>
field = 'their_did', field_id = 'EerQqea4HRFpfRXxY8EgJe'
desired_state = 'request-received', timeout = Timeout(timeout=45)
look_back = 15

    async def wait_for_event(
        self,
        field,
        field_id,
        desired_state,
        timeout: int = DEFAULT_LISTENER_TIMEOUT,
        look_back: int = 15,
    ) -> Dict[str, Any]:
        """
        Start listening for SSE events. When an event is received that matches the specified parameters.
        """
        url = f"{waypoint_base_url}/{self.wallet_id}/{self.topic}/{field}/{field_id}/{desired_state}"
        params = {"look_back": look_back}
    
        timeout = Timeout(timeout)
        async with RichAsyncClient(timeout=timeout) as client:
            async with client.stream("GET", url, params=params) as response:
                async for line in response.aiter_lines():
                    if line.startswith("data: "):
                        data = json.loads(line[6:])
                        return data["payload"]
                    elif line == "" or line.startswith(": ping"):
                        pass  # ignore newlines and pings
                    else:
                        logger.warning("Unexpected SSE line: {}", line)
    
>       raise SseListenerTimeout("Requested filtered event was not returned by server.")
E       app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server.

app/tests/util/sse_listener.py:58: SseListenerTimeout

Check failure on line 1 in app/tests/e2e/issuer/test_save_exchange_record.py

GitHub Actions / JUnit Test Report

test_save_exchange_record.test_request_credential_with_save_exchange_record[clean-clean-clean-clean-clean-True]

failed on setup with "app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server."
Raw output
anyio_backend = 'asyncio'
request = <SubRequest 'faber_and_alice_connection' for <Function test_request_credential_with_save_exchange_record[clean-clean-clean-clean-clean-True]>>
args = ()
kwargs = {'alice_member_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f60795ddc70>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f60789ec7d0>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7f6080f79620>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7f60800530e0>

    def wrapper(
        *args: Any, anyio_backend: Any, request: SubRequest, **kwargs: Any
    ) -> Any:
        # Rebind any fixture methods to the request instance
        if (
            request.instance
            and ismethod(func)
            and type(func.__self__) is type(request.instance)
        ):
            local_func = func.__func__.__get__(request.instance)
        else:
            local_func = func
    
        backend_name, backend_options = extract_backend_and_options(anyio_backend)
        if has_backend_arg:
            kwargs["anyio_backend"] = anyio_backend
    
        if has_request_arg:
            kwargs["request"] = request
    
        with get_runner(backend_name, backend_options) as runner:
            if isasyncgenfunction(local_func):
                yield from runner.run_asyncgen_fixture(local_func, kwargs)
            else:
>               yield runner.run_fixture(local_func, kwargs)

/usr/local/lib/python3.13/site-packages/anyio/pytest_plugin.py:100: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2256: in run_fixture
    retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.13/asyncio/base_events.py:720: in run_until_complete
    return future.result()
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2226: in _call_in_runner_task
    return await future
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2193: in _run_tests_and_fixtures
    retval = await coro
app/tests/fixtures/member_connections.py:46: in faber_and_alice_connection
    bob_alice_connection = await create_connection_by_test_mode(
app/tests/util/connections.py:202: in create_connection_by_test_mode
    return await create_did_exchange(
app/tests/util/connections.py:332: in create_did_exchange
    bob_connection = await check_webhook_state(
app/tests/util/webhooks.py:59: in check_webhook_state
    event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <app.tests.util.sse_listener.SseListener object at 0x7f6078d767b0>
field = 'their_did', field_id = 'AbzHM4TWhCA3FPXN4W4UtC'
desired_state = 'request-received', timeout = Timeout(timeout=45)
look_back = 15

    async def wait_for_event(
        self,
        field,
        field_id,
        desired_state,
        timeout: int = DEFAULT_LISTENER_TIMEOUT,
        look_back: int = 15,
    ) -> Dict[str, Any]:
        """
        Start listening for SSE events. When an event is received that matches the specified parameters.
        """
        url = f"{waypoint_base_url}/{self.wallet_id}/{self.topic}/{field}/{field_id}/{desired_state}"
        params = {"look_back": look_back}
    
        timeout = Timeout(timeout)
        async with RichAsyncClient(timeout=timeout) as client:
            async with client.stream("GET", url, params=params) as response:
                async for line in response.aiter_lines():
                    if line.startswith("data: "):
                        data = json.loads(line[6:])
                        return data["payload"]
                    elif line == "" or line.startswith(": ping"):
                        pass  # ignore newlines and pings
                    else:
                        logger.warning("Unexpected SSE line: {}", line)
    
>       raise SseListenerTimeout("Requested filtered event was not returned by server.")
E       app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server.

app/tests/util/sse_listener.py:58: SseListenerTimeout

Check failure on line 1 in app/tests/e2e/issuer/test_save_exchange_record.py

GitHub Actions / JUnit Test Report

test_save_exchange_record.test_get_cred_exchange_records[clean-clean-clean-clean-clean]

failed on setup with "app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server."
Raw output
anyio_backend = 'asyncio'
request = <SubRequest 'faber_and_alice_connection' for <Function test_get_cred_exchange_records[clean-clean-clean-clean-clean]>>
args = ()
kwargs = {'alice_member_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f608bd254f0>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7f60789ec7d0>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7f6080f79620>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7f60800530e0>

    def wrapper(
        *args: Any, anyio_backend: Any, request: SubRequest, **kwargs: Any
    ) -> Any:
        # Rebind any fixture methods to the request instance
        if (
            request.instance
            and ismethod(func)
            and type(func.__self__) is type(request.instance)
        ):
            local_func = func.__func__.__get__(request.instance)
        else:
            local_func = func
    
        backend_name, backend_options = extract_backend_and_options(anyio_backend)
        if has_backend_arg:
            kwargs["anyio_backend"] = anyio_backend
    
        if has_request_arg:
            kwargs["request"] = request
    
        with get_runner(backend_name, backend_options) as runner:
            if isasyncgenfunction(local_func):
                yield from runner.run_asyncgen_fixture(local_func, kwargs)
            else:
>               yield runner.run_fixture(local_func, kwargs)

/usr/local/lib/python3.13/site-packages/anyio/pytest_plugin.py:100: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2256: in run_fixture
    retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.13/asyncio/base_events.py:720: in run_until_complete
    return future.result()
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2226: in _call_in_runner_task
    return await future
/usr/local/lib/python3.13/site-packages/anyio/_backends/_asyncio.py:2193: in _run_tests_and_fixtures
    retval = await coro
app/tests/fixtures/member_connections.py:46: in faber_and_alice_connection
    bob_alice_connection = await create_connection_by_test_mode(
app/tests/util/connections.py:202: in create_connection_by_test_mode
    return await create_did_exchange(
app/tests/util/connections.py:332: in create_did_exchange
    bob_connection = await check_webhook_state(
app/tests/util/webhooks.py:59: in check_webhook_state
    event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <app.tests.util.sse_listener.SseListener object at 0x7f60789d59d0>
field = 'their_did', field_id = 'LrbuF7ehurZwjtTWEz6W4d'
desired_state = 'request-received', timeout = Timeout(timeout=45)
look_back = 15

    async def wait_for_event(
        self,
        field,
        field_id,
        desired_state,
        timeout: int = DEFAULT_LISTENER_TIMEOUT,
        look_back: int = 15,
    ) -> Dict[str, Any]:
        """
        Start listening for SSE events. When an event is received that matches the specified parameters.
        """
        url = f"{waypoint_base_url}/{self.wallet_id}/{self.topic}/{field}/{field_id}/{desired_state}"
        params = {"look_back": look_back}
    
        timeout = Timeout(timeout)
        async with RichAsyncClient(timeout=timeout) as client:
            async with client.stream("GET", url, params=params) as response:
                async for line in response.aiter_lines():
                    if line.startswith("data: "):
                        data = json.loads(line[6:])
                        return data["payload"]
                    elif line == "" or line.startswith(": ping"):
                        pass  # ignore newlines and pings
                    else:
                        logger.warning("Unexpected SSE line: {}", line)
    
>       raise SseListenerTimeout("Requested filtered event was not returned by server.")
E       app.tests.util.sse_listener.SseListenerTimeout: Requested filtered event was not returned by server.

app/tests/util/sse_listener.py:58: SseListenerTimeout
import json
from typing import Optional