5062221e78
Configurables did not allow more than one "method" option, and mixed scenarios (options+methods+...) were sometimes flaky, forcing the user to know what order was the right one. Now, all options work the same, sharing the same "order" namespace. Backward incompatible change: Options are now required by default, unless a default is provided. Also adds a few candies for debugging/testing, found in the bonobo.util.inspect module.
76 lines
1.8 KiB
Python
76 lines
1.8 KiB
Python
from unittest.mock import MagicMock
|
|
|
|
import pytest
|
|
|
|
import bonobo
|
|
from bonobo.config.processors import ContextCurrifier
|
|
from bonobo.constants import NOT_MODIFIED
|
|
from bonobo.util.inspect import inspect_node
|
|
|
|
|
|
def test_count():
|
|
with pytest.raises(TypeError):
|
|
bonobo.count()
|
|
|
|
context = MagicMock()
|
|
|
|
with ContextCurrifier(bonobo.count).as_contextmanager(context) as stack:
|
|
for i in range(42):
|
|
stack()
|
|
|
|
assert len(context.method_calls) == 1
|
|
bag = context.send.call_args[0][0]
|
|
assert isinstance(bag, bonobo.Bag)
|
|
assert 0 == len(bag.kwargs)
|
|
assert 1 == len(bag.args)
|
|
assert bag.args[0] == 42
|
|
|
|
|
|
def test_identity():
|
|
assert bonobo.identity(42) == 42
|
|
|
|
|
|
def test_limit():
|
|
context, results = MagicMock(), []
|
|
|
|
with ContextCurrifier(bonobo.Limit(2)).as_contextmanager(context) as stack:
|
|
for i in range(42):
|
|
results += list(stack())
|
|
|
|
assert results == [NOT_MODIFIED] * 2
|
|
|
|
|
|
def test_limit_not_there():
|
|
context, results = MagicMock(), []
|
|
|
|
with ContextCurrifier(bonobo.Limit(42)).as_contextmanager(context) as stack:
|
|
for i in range(10):
|
|
results += list(stack())
|
|
|
|
assert results == [NOT_MODIFIED] * 10
|
|
|
|
|
|
def test_limit_default():
|
|
context, results = MagicMock(), []
|
|
|
|
with ContextCurrifier(bonobo.Limit()).as_contextmanager(context) as stack:
|
|
for i in range(20):
|
|
results += list(stack())
|
|
|
|
assert results == [NOT_MODIFIED] * 10
|
|
|
|
|
|
def test_tee():
|
|
inner = MagicMock(side_effect=bonobo.identity)
|
|
tee = bonobo.Tee(inner)
|
|
results = []
|
|
for i in range(10):
|
|
results.append(tee('foo'))
|
|
|
|
assert results == [NOT_MODIFIED] * 10
|
|
assert len(inner.mock_calls) == 10
|
|
|
|
|
|
def test_noop():
|
|
assert bonobo.noop(1, 2, 3, 4, foo='bar') == NOT_MODIFIED
|