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:18:19 +02:00
commit a37da37bbf
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pyinfra/visitor/visitor.py
View File

@ -3,7 +3,7 @@ from typing import Callable
from funcy import lflatten, compose from funcy import lflatten, compose
from pyinfra.storage.storage import Storage 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.formatter import ResponseFormatter
from pyinfra.visitor.response_formatter.formatters.identity import IdentityResponseFormatter from pyinfra.visitor.response_formatter.formatters.identity import IdentityResponseFormatter
from pyinfra.visitor.strategies.blob_parsing.blob_parsing import BlobParsingStrategy 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.""" """Bundles the result from processing a storage item with the body of the corresponding queue item."""
callback_results = compose( callback_results = compose(
flift(any),
lflatten, lflatten,
lift(self.get_item_processor(queue_item_body)), lift(self.get_item_processor(queue_item_body)),
self.load_data, self.load_data,