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 #908 from krish7919/bug/781/performance-memory-usage

Browse Source 
Fix 781 and 124
This commit is contained in:
Krish 2016-12-08 13:51:05 +01:00 committed by GitHub
commit 07b3f9ca4e
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
bigchaindb/pipelines/block.py
View File

@ -8,7 +8,7 @@ function.
import logging
import rethinkdb as r
from multipipes import Pipeline, Node
from multipipes import Pipeline, Node, Pipe
from bigchaindb.models import Transaction
from bigchaindb.pipelines.utils import ChangeFeed
@ -161,6 +161,7 @@ def create_pipeline():
block_pipeline = BlockPipeline()
pipeline = Pipeline([
Pipe(maxsize=1000),
Node(block_pipeline.filter_tx),
Node(block_pipeline.validate_tx, fraction_of_cores=1),
Node(block_pipeline.create, timeout=1),