PR #1231 #3597
GitHub Actions / JUnit Test Report
failed
Dec 12, 2024 in 0s
887 tests run, 874 passed, 6 skipped, 7 failed.
Annotations
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 0x7fe51c58fcb0>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fe51b956870>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7fe51fa316c0>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7fe51b90b4a0>
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.12/site-packages/anyio/pytest_plugin.py:100:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2300: in run_fixture
retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.12/asyncio/base_events.py:686: in run_until_complete
return future.result()
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2270: in _call_in_runner_task
return await future
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2237: 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:58: in check_webhook_state
event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <app.tests.util.sse_listener.SseListener object at 0x7fe51c136e70>
field = 'their_did', field_id = 'RGgGRCG7LnZtaGPDLjsYdk'
desired_state = 'request-received', timeout = Timeout(timeout=45)
async def wait_for_event(
self,
field,
field_id,
desired_state,
timeout: int = DEFAULT_LISTENER_TIMEOUT,
) -> 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}?look_back=5"
timeout = Timeout(timeout)
async with RichAsyncClient(timeout=timeout) as client:
async with client.stream("GET", url) 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:56: 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 0x7fe51c100770>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fe51b956870>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7fe51fa316c0>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7fe51b90b4a0>
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.12/site-packages/anyio/pytest_plugin.py:100:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2300: in run_fixture
retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.12/asyncio/base_events.py:686: in run_until_complete
return future.result()
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2270: in _call_in_runner_task
return await future
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2237: 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:58: in check_webhook_state
event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <app.tests.util.sse_listener.SseListener object at 0x7fe51c136db0>
field = 'their_did', field_id = 'JQMkmdCG3mTK3GMSbNq4Fb'
desired_state = 'request-received', timeout = Timeout(timeout=45)
async def wait_for_event(
self,
field,
field_id,
desired_state,
timeout: int = DEFAULT_LISTENER_TIMEOUT,
) -> 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}?look_back=5"
timeout = Timeout(timeout)
async with RichAsyncClient(timeout=timeout) as client:
async with client.stream("GET", url) 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:56: 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 0x7fe51c1c9af0>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fe51b956870>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7fe51fa316c0>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7fe51b90b4a0>
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.12/site-packages/anyio/pytest_plugin.py:100:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2300: in run_fixture
retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.12/asyncio/base_events.py:686: in run_until_complete
return future.result()
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2270: in _call_in_runner_task
return await future
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2237: 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:58: in check_webhook_state
event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <app.tests.util.sse_listener.SseListener object at 0x7fe51b954a70>
field = 'their_did', field_id = 'P6mfDdN3w1p6ux9ik7ZYxV'
desired_state = 'request-received', timeout = Timeout(timeout=45)
async def wait_for_event(
self,
field,
field_id,
desired_state,
timeout: int = DEFAULT_LISTENER_TIMEOUT,
) -> 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}?look_back=5"
timeout = Timeout(timeout)
async with RichAsyncClient(timeout=timeout) as client:
async with client.stream("GET", url) 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:56: 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 0x7fe51c109490>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fe51b956870>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7fe51fa316c0>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7fe51b90b4a0>
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.12/site-packages/anyio/pytest_plugin.py:100:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2300: in run_fixture
retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.12/asyncio/base_events.py:686: in run_until_complete
return future.result()
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2270: in _call_in_runner_task
return await future
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2237: 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:58: in check_webhook_state
event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <app.tests.util.sse_listener.SseListener object at 0x7fe51c10ba10>
field = 'their_did', field_id = 'TU5dGy4T6BfaD1kV8Xup9H'
desired_state = 'request-received', timeout = Timeout(timeout=45)
async def wait_for_event(
self,
field,
field_id,
desired_state,
timeout: int = DEFAULT_LISTENER_TIMEOUT,
) -> 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}?look_back=5"
timeout = Timeout(timeout)
async with RichAsyncClient(timeout=timeout) as client:
async with client.stream("GET", url) 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:56: 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 0x7fe51c102ab0>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fe51b956870>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7fe51fa316c0>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7fe51b90b4a0>
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.12/site-packages/anyio/pytest_plugin.py:100:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2300: in run_fixture
retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.12/asyncio/base_events.py:686: in run_until_complete
return future.result()
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2270: in _call_in_runner_task
return await future
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2237: 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:58: in check_webhook_state
event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <app.tests.util.sse_listener.SseListener object at 0x7fe51c109af0>
field = 'their_did', field_id = 'FMis28A6n7aqESbyVHWSx'
desired_state = 'request-received', timeout = Timeout(timeout=45)
async def wait_for_event(
self,
field,
field_id,
desired_state,
timeout: int = DEFAULT_LISTENER_TIMEOUT,
) -> 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}?look_back=5"
timeout = Timeout(timeout)
async with RichAsyncClient(timeout=timeout) as client:
async with client.stream("GET", url) 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:56: 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 0x7fe51c10a7e0>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fe51b956870>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7fe51fa316c0>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7fe51b90b4a0>
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.12/site-packages/anyio/pytest_plugin.py:100:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2300: in run_fixture
retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.12/asyncio/base_events.py:686: in run_until_complete
return future.result()
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2270: in _call_in_runner_task
return await future
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2237: 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:58: in check_webhook_state
event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <app.tests.util.sse_listener.SseListener object at 0x7fe51c517890>
field = 'their_did', field_id = 'V6hbYh5asmLyvznPnKPbSi'
desired_state = 'request-received', timeout = Timeout(timeout=45)
async def wait_for_event(
self,
field,
field_id,
desired_state,
timeout: int = DEFAULT_LISTENER_TIMEOUT,
) -> 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}?look_back=5"
timeout = Timeout(timeout)
async with RichAsyncClient(timeout=timeout) as client:
async with client.stream("GET", url) 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:56: 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 0x7fe51c183410>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fe51b956870>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7fe51fa316c0>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7fe51b90b4a0>
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.12/site-packages/anyio/pytest_plugin.py:100:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2300: in run_fixture
retval = self.get_loop().run_until_complete(
/usr/local/lib/python3.12/asyncio/base_events.py:686: in run_until_complete
return future.result()
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2270: in _call_in_runner_task
return await future
/usr/local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py:2237: 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:58: in check_webhook_state
event = await listener.wait_for_event(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <app.tests.util.sse_listener.SseListener object at 0x7fe51c180530>
field = 'their_did', field_id = 'ADUsASBiECXpeim4HiQfax'
desired_state = 'request-received', timeout = Timeout(timeout=45)
async def wait_for_event(
self,
field,
field_id,
desired_state,
timeout: int = DEFAULT_LISTENER_TIMEOUT,
) -> 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}?look_back=5"
timeout = Timeout(timeout)
async with RichAsyncClient(timeout=timeout) as client:
async with client.stream("GET", url) 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:56: SseListenerTimeout
Loading