Fix test_catchup_with_old_txn_metadata_digest_format
@@ -5,7 +5,7 @@ from plenum.common.constants import TXN_PAYLOAD, TXN_PAYLOAD_METADATA, TXN_PAYLO
TXN_PAYLOAD_METADATA_PAYLOAD_DIGEST
from plenum.common.txn_util import append_payload_metadata
from plenum.test.delayers import delay_3pc
-from plenum.test.helper import sdk_send_random_requests
+from plenum.test.helper import sdk_send_random_requests, sdk_get_replies
from plenum.test.node_catchup.helper import ensure_all_nodes_have_same_data
from plenum.test.stasher import delay_rules_without_processing
from stp_core.loop.eventually import eventually
@@ -46,10 +46,13 @@ def test_catchup_with_old_txn_metadata_digest_format(tdir, tconf,
# Order some transactions, with one node discarding messages
with delay_rules_without_processing(lagging_stasher, delay_3pc()):
- sdk_send_random_requests(looper, sdk_pool_handle, sdk_wallet_client, 10)
+ reps = sdk_send_random_requests(looper, sdk_pool_handle, sdk_wallet_client, 10)
looper.run(eventually(check_nodes_domain_ledger, other_nodes, initial_size + 10))
assert lagging_node.domainLedger.size == initial_size
# Catchup transactions and ensure that all nodes will eventually have same data
lagging_node.start_catchup()
ensure_all_nodes_have_same_data(looper, txnPoolNodeSet)
+
+ # Catch replies
+ sdk_get_replies(looper, reps)
