diff --git a/bigchaindb/pipelines/block.py b/bigchaindb/pipelines/block.py
index 14e9e5a4..d666591b 100644
--- a/bigchaindb/pipelines/block.py
+++ b/bigchaindb/pipelines/block.py
@@ -6,7 +6,7 @@ function.
 """
 
 import logging
-from multipipes import Pipeline, Node
+from multipipes import Pipeline, Node, Pipe
 
 import bigchaindb
 from bigchaindb.backend import connect, get_changefeed