diff --git a/src/parallax/server/executor.py b/src/parallax/server/executor.py index 933c397..bb22768 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()