Results 4 comments of dzlabs

Quick workaround ``` from faust.exceptions import SameNode app.router.route_req = AsyncMock(side_effect=SameNode) ```

Also having this issue, seems to be related to using take `.take(100, within=300)`