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

make stepping pipeline queue items mutable

Browse Source
This commit is contained in:
Scott Sadler 2017-03-17 15:34:17 +01:00
parent bbf5c49f9a
commit 03ca4b1fd3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/pipelines/stepping.py
View File

@ -106,7 +106,7 @@ class MultipipesStepper:
for item in items: for item in items:
if type(item) != tuple: if type(item) != tuple:
item = (item,) item = (item,)
queue.append(item) queue.append(list(item))
def step(self, name, **kwargs): def step(self, name, **kwargs):
""" Advance pipeline stage. Throws Empty if no data to consume. """ """ Advance pipeline stage. Throws Empty if no data to consume. """