From 8b9f331f8b8da2a078519e9d09070484f61a5fd2 Mon Sep 17 00:00:00 2001 From: Robin Dittrich Date: Tue, 11 Nov 2025 10:20:34 +0100 Subject: [PATCH 1/2] feat(executor): initialize http_requests list for ingesting new requests --- src/parallax/server/executor.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/parallax/server/executor.py b/src/parallax/server/executor.py index 933c397..23ce216 100644 --- a/src/parallax/server/executor.py +++ b/src/parallax/server/executor.py @@ -1197,6 +1197,8 @@ def run_loop(self): self._should_stop = False while not self._should_stop: # 1. Ingest new requests from the http frontend + http_requests = [] + if self.is_first_peer: http_requests = self.recv_requests_from_http() From bc9ac6d895ec3d775e796f152e900e3538822f60 Mon Sep 17 00:00:00 2001 From: Robin Dittrich Date: Tue, 11 Nov 2025 16:18:17 +0100 Subject: [PATCH 2/2] fix pre-commit errors --- src/parallax/server/executor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/parallax/server/executor.py b/src/parallax/server/executor.py index 23ce216..bb22768 100644 --- a/src/parallax/server/executor.py +++ b/src/parallax/server/executor.py @@ -1198,7 +1198,7 @@ def run_loop(self): while not self._should_stop: # 1. Ingest new requests from the http frontend http_requests = [] - + if self.is_first_peer: http_requests = self.recv_requests_from_http()