fixed initial computation queue state

2022-05-05 16:42:43 +02:00 · 2022-05-05 16:42:43 +02:00 · 4a3ac150cf
commit 4a3ac150cf
parent 373c38113f
1 changed files with 1 additions and 1 deletions
--- 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):