diff --git a/pyinfra/visitor/visitor.py b/pyinfra/visitor/visitor.py
index 32d1d23..7df8aaf 100644
--- a/pyinfra/visitor/visitor.py
+++ b/pyinfra/visitor/visitor.py
@@ -3,7 +3,7 @@ from typing import Callable
 from funcy import lflatten, compose
 
 from pyinfra.storage.storage import Storage
-from pyinfra.utils.func import lift
+from pyinfra.utils.func import lift, flift
 from pyinfra.visitor.response_formatter.formatter import ResponseFormatter
 from pyinfra.visitor.response_formatter.formatters.identity import IdentityResponseFormatter
 from pyinfra.visitor.strategies.blob_parsing.blob_parsing import BlobParsingStrategy
@@ -54,6 +54,7 @@ class QueueVisitor:
         """Bundles the result from processing a storage item with the body of the corresponding queue item."""
 
         callback_results = compose(
+            flift(any),
             lflatten,
             lift(self.get_item_processor(queue_item_body)),
             self.load_data,