From c8579a8ad05841acb987618d666382a77510bc6d Mon Sep 17 00:00:00 2001 From: Matthias Bisping Date: Tue, 10 May 2022 12:49:36 +0200 Subject: [PATCH] renaming --- pyinfra/server/bufferizer/lazy_bufferizer.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pyinfra/server/bufferizer/lazy_bufferizer.py b/pyinfra/server/bufferizer/lazy_bufferizer.py index 96a677d..614378a 100644 --- a/pyinfra/server/bufferizer/lazy_bufferizer.py +++ b/pyinfra/server/bufferizer/lazy_bufferizer.py @@ -14,12 +14,12 @@ logger = logging.getLogger(__name__) class LazyBufferizer: def __init__(self, fn, buffer_size=3): """Function `fn` has to return an iterable, ideally is a generator and needs to be mappable.""" - self.execution_queue = chain([]) + self.input_queue = chain([]) self.fn = bufferize(fn, buffer_size=buffer_size, null_value=[]) self.result_stream = chain([]) def submit(self, package, **kwargs) -> None: - self.execution_queue = chain(self.execution_queue, [package]) + self.input_queue = chain(self.input_queue, [package]) def compute_next(self) -> Union[Nothing, Any]: try: @@ -31,6 +31,6 @@ class LazyBufferizer: raise TypeError("Function failed with type error. Is it mappable?") from err def compute(self): - items = chain(self.execution_queue, [Nothing]) + items = chain(self.input_queue, [Nothing]) yield from compose(flatten, lift(self.fn))(items) yield Nothing