Fix failing job

This commit is contained in:
Aya Hassan 2026-06-24 18:34:59 +02:00
parent 697ecf8d99
commit e6288178f3
2 changed files with 14 additions and 3 deletions

View File

@ -55,7 +55,10 @@ jobs:
- name: Run tests
timeout-minutes: 30
run: |
pytest -m 'smoke' -n 4 --dist=loadgroup --reruns 1 --junit-xml=pytest_results.xml
pytest -m 'smoke' -n 4 --dist=loadgroup --reruns 1 \
--ignore=tests/wrappers_tests \
--ignore=vendor/logos-delivery-python-bindings/tests \
--junit-xml=pytest_results.xml
- name: Test Report
if: always()

View File

@ -11,6 +11,7 @@ from src.node.wrapper_helpers import (
assert_event_invariants,
create_message_bindings,
get_node_multiaddr,
wait_for_connected,
wait_for_propagated,
wait_for_sent,
wait_for_error,
@ -706,10 +707,17 @@ class TestS26LightpushPeerChurn(StepsCommon):
assert sender_result.is_ok(), f"Failed to start sender: {sender_result.err()}"
with sender_result.ok_value as sender_node:
delay(2)
# Gate on the sender actually reporting Connected/
# PartiallyConnected before inducing churn. The previous
# blind delay raced the lightpush connection setup, so peer1
# was sometimes stopped before the sender had a warm path to
# the surviving peer2, leaving no propagation route.
assert wait_for_connected(sender_collector) is not None, (
f"Sender did not reach Connected/PartiallyConnected state " f"before peer churn. Collected events: {sender_collector.events}"
)
stop_result = peer1.stop_and_destroy()
assert stop_result.is_ok(), f"Failed to stop peer1: {stop_result.err()}"
delay(2)
delay(SERVICE_DOWN_SETTLE_S)
message = create_message_bindings()
send_result = sender_node.send_message(message=message)