mirrors/dragonflydb-dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2024-12-14 11:58:02 +00:00
Code Activity

fix(test): add wait for all replicas to finish (#1124)

Browse source 
Signed-off-by: adi_holden <adi@dragonflydb.io>
This commit is contained in:
adiholden 2023-04-23 14:20:01 +03:00 committed by GitHub
parent 520e66c4b7
commit c6d34678f3
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
tests/dragonfly/replication_test.py
View file

@ -467,9 +467,8 @@ async def test_flushall(df_local_factory):
n_keys, n_keys*2), batch_size=3)
await pipe.execute()
# Wait for replica to receive them
await asyncio.sleep(1)
# Check replica finished executing the replicated commands
await check_all_replicas_finished([c_replica], c_master)
# Check replica keys 0..n_keys-1 dont exist
pipe = c_replica.pipeline(transaction=False)