20
20
from plenum .common .util import randomString , hexToFriendly
21
21
from plenum .test .helper import waitForSufficientRepliesForRequests , \
22
22
sdk_sign_request_objects , sdk_send_signed_requests , \
23
- sdk_json_to_request_object , sdk_get_and_check_replies
23
+ sdk_json_to_request_object , sdk_get_and_check_replies , sdk_send_random_and_check
24
24
from plenum .test .test_client import TestClient , genTestClient
25
25
from plenum .test .test_node import TestNode , \
26
26
ensure_node_disconnected , checkNodesConnected
@@ -485,6 +485,7 @@ def update_node_data_and_reconnect(looper, txnPoolNodeSet,
485
485
# restart the Node with new HA
486
486
node .stop ()
487
487
looper .removeProdable (name = node .name )
488
+ sdk_send_random_and_check (looper , txnPoolNodeSet , sdk_pool_handle , steward_wallet , 1 )
488
489
config_helper = PNodeConfigHelper (node .name , tconf , chroot = tdir )
489
490
restartedNode = TestNode (node .name ,
490
491
config_helper = config_helper ,
@@ -502,7 +503,7 @@ def update_node_data_and_reconnect(looper, txnPoolNodeSet,
502
503
except StopIteration :
503
504
raise Exception ('{} is not the pool' .format (node ))
504
505
txnPoolNodeSet [idx ] = restartedNode
505
-
506
+ sdk_send_random_and_check ( looper , txnPoolNodeSet , sdk_pool_handle , steward_wallet , 1 )
506
507
looper .run (checkNodesConnected (txnPoolNodeSet ))
507
508
sdk_pool_refresh (looper , sdk_pool_handle )
508
509
return restartedNode
0 commit comments