filtering of empty data-metadata packs adjusted for dicts instead of tuples

This commit is contained in:
Matthias Bisping 2022-06-22 16:22:44 +02:00
parent 99e7f059a7
commit ac1d9781e8

View File

@ -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,