Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

Merge branch '2.0.0-input-output-file-pattern-for-download-strategy' of ssh://git.iqser.com:2222/rr/pyinfra into 2.0.0-input-output-file-pattern-for-download-strategy

Browse Source
This commit is contained in:
Julius Unverfehrt 2022-06-22 16:24:30 +02:00
commit 5363c632d7
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pyinfra/visitor/visitor.py
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,