diff --git a/pyinfra/visitor/visitor.py b/pyinfra/visitor/visitor.py index 7df8aaf..c872d14 100644 --- a/pyinfra/visitor/visitor.py +++ b/pyinfra/visitor/visitor.py @@ -1,7 +1,8 @@ from typing import Callable -from funcy import lflatten, compose +from funcy import lflatten, compose, itervalues +from pyinfra.server.debugging import inspect from pyinfra.storage.storage import Storage from pyinfra.utils.func import lift, flift from pyinfra.visitor.response_formatter.formatter import ResponseFormatter @@ -54,7 +55,7 @@ class QueueVisitor: """Bundles the result from processing a storage item with the body of the corresponding queue item.""" callback_results = compose( - flift(any), + flift(compose(any, itervalues)), lflatten, lift(self.get_item_processor(queue_item_body)), self.load_data,