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

Merge pull request #846 from bigchaindb/fix-stale-pipeline-bug

Browse Source 
Fix race condition in test_stale_monitor.py:test_full_pipeline
This commit is contained in:
libscott 2016-11-24 09:53:26 +01:00 committed by GitHub
commit 957a548465
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tests/pipelines/test_stale_monitor.py
View File

@ -77,7 +77,6 @@ def test_full_pipeline(monkeypatch, user_pk):
}
config_utils.set_config(CONFIG)
b = Bigchain()
outpipe = Pipe()
original_txs = {}
original_txc = []
@ -96,9 +95,15 @@ def test_full_pipeline(monkeypatch, user_pk):
monkeypatch.undo()
inpipe = Pipe()
# Each time the StaleTransactionMonitor pipeline runs, it reassigns
# all eligible transactions. Passing this inpipe prevents that from
# taking place more than once.
inpipe.put(())
outpipe = Pipe()
pipeline = stale.create_pipeline(backlog_reassign_delay=1,
timeout=1)
pipeline.setup(outdata=outpipe)
pipeline.setup(indata=inpipe, outdata=outpipe)
pipeline.start()
# to terminate