Push on master #3605
GitHub Actions / JUnit Test Report
failed
Dec 13, 2024 in 0s
888 tests run, 878 passed, 6 skipped, 4 failed.
Annotations
Check failure on line 1 in app/tests/e2e/verifier/test_predicate_proofs.py
github-actions / JUnit Test Report
test_predicate_proofs.test_predicate_proofs[clean-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_predicate_proofs[clean-clean-clean-clean-clean-clean-<]>>
args = ()
kwargs = {'alice_member_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fc8d535cb30>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fc8d57ff380>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7fc8dc7905e0>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7fc8d532bda0>
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 0x7fc8d431f7a0>
field = 'their_did', field_id = 'HSvr73JC1yF3KZf2nzvYan'
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/verifier/test_predicate_proofs.py
github-actions / JUnit Test Report
test_predicate_proofs.test_predicate_proofs[clean-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_predicate_proofs[clean-clean-clean-clean-clean-clean->]>>
args = ()
kwargs = {'alice_member_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fc8d436cb60>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fc8d57ff380>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7fc8dc7905e0>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7fc8d532bda0>
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 0x7fc8d438ce60>
field = 'their_did', field_id = 'UnVZZNv8MB5YYco1dE1wxb'
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/verifier/test_predicate_proofs.py
github-actions / JUnit Test Report
test_predicate_proofs.test_predicate_proofs[clean-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_predicate_proofs[clean-clean-clean-clean-clean-clean-<=]>>
args = ()
kwargs = {'alice_member_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fc8d43916d0>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fc8d57ff380>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7fc8dc7905e0>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7fc8d532bda0>
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 0x7fc8d4320dd0>
field = 'their_did', field_id = '8DV9SQAeok5r8qPMQy4HxW'
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/verifier/test_predicate_proofs.py
github-actions / JUnit Test Report
test_predicate_proofs.test_predicate_proofs[clean-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_predicate_proofs[clean-clean-clean-clean-clean-clean->=]>>
args = ()
kwargs = {'alice_member_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fc8d436dd30>, 'faber_client': <shared.util.rich_async_client.RichAsyncClient object at 0x7fc8d57ff380>, 'test_mode': 'clean'}
local_func = <function faber_and_alice_connection at 0x7fc8dc7905e0>
backend_name = 'asyncio', backend_options = {}
runner = <anyio._backends._asyncio.TestRunner object at 0x7fc8d532bda0>
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 0x7fc8d438d100>
field = 'their_did', field_id = 'B77EyjQ6BtttiDsDYJ6Nqm'
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