diff --git a/bigchaindb/backend/rethinkdb/query.py b/bigchaindb/backend/rethinkdb/query.py index 3521f0c3..3ee90f34 100644 --- a/bigchaindb/backend/rethinkdb/query.py +++ b/bigchaindb/backend/rethinkdb/query.py @@ -260,7 +260,7 @@ def get_last_voted_block_id(connection, node_pubkey): @register_query(RethinkDBConnection) -def get_new_blocks_feed(connection, start_block_id): +def get_new_blocks_feed(connection, start_block_id): # pragma: no cover logger.warning('RethinkDB changefeed unable to resume from given block: %s', start_block_id) # In order to get blocks in the correct order, it may be acceptable to diff --git a/tests/pipelines/test_vote.py b/tests/pipelines/test_vote.py index b61b3cb4..c170cd04 100644 --- a/tests/pipelines/test_vote.py +++ b/tests/pipelines/test_vote.py @@ -584,18 +584,3 @@ def test_vote_no_double_inclusion(b): b.write_block(block) r = vote.Vote().validate_tx(tx, 'other_block_id', 1) assert r == (False, 'other_block_id', 1) - - -@pytest.mark.genesis -def test_vote_changefeed(b): - from bigchaindb.pipelines import vote - from multiprocessing import Queue - - changefeed = vote.get_changefeed() - changefeed.outqueue = Queue() - changefeed.start() - tx = dummy_tx(b) - block = b.create_block([tx]) - b.write_block(block) - assert changefeed.outqueue.get() == block.decouple_assets()[1] - changefeed.terminate()