diff --git a/pyinfra/server/server.py b/pyinfra/server/server.py index d88c2dd..afd6828 100644 --- a/pyinfra/server/server.py +++ b/pyinfra/server/server.py @@ -29,7 +29,7 @@ def make_processor_fn(operation, buffer_size, batched): class Processor(abc.ABC): def __init__(self, processor_fn): - self.execution_queue = [] + self.execution_queue = chain([]) self.processor_fn = processor_fn def run(self, package, final):