Mirroristas/bigchaindb
2
0
Fork 0
mirror of https://github.com/bigchaindb/bigchaindb.git synced 2024-10-13 13:34:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

sleep

Browse Source
This commit is contained in:
ryan 2016-08-01 16:24:27 +02:00
parent 68f64ee780
commit dd0b758bfa
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
bigchaindb/pipelines/election.py
View File

@ -48,4 +48,4 @@ def start():
pipeline = create_pipeline() pipeline = create_pipeline()
pipeline.setup(indata=get_changefeed()) pipeline.setup(indata=get_changefeed())
pipeline.start() pipeline.start()
return pipeline return pipeline

4
tests/pipelines/test_election.py
View File

@ -83,7 +83,7 @@ def test_start(mock_start):
mock_start.assert_called_with() mock_start.assert_called_with()
def test_full_pipline(b, user_vk): def test_full_pipeline(b, user_vk):
outpipe = Pipe() outpipe = Pipe()
# write two blocks # write two blocks
@ -108,7 +108,7 @@ def test_full_pipline(b, user_vk):
pipeline = election.create_pipeline() pipeline = election.create_pipeline()
pipeline.setup(indata=election.get_changefeed(), outdata=outpipe) pipeline.setup(indata=election.get_changefeed(), outdata=outpipe)
pipeline.start() pipeline.start()
time.sleep(1)
# vote one block valid, one invalid # vote one block valid, one invalid
vote_valid = b.vote(valid_block['id'], 'abc', True) vote_valid = b.vote(valid_block['id'], 'abc', True)
vote_invalid = b.vote(invalid_block['id'], 'abc', False) vote_invalid = b.vote(invalid_block['id'], 'abc', False)