Deq

lidofinance · Aug 29, 2024 · 90155aa · 90155aa
1 parent 566a4aa
commit 90155aa
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/transport/msg_providers/data_bus.py b/src/transport/msg_providers/data_bus.py
@@ -1,5 +1,6 @@
 import abc
 import logging
+from collections import deque
 from enum import Enum
 from typing import List, Optional
 
@@ -219,7 +220,7 @@ def __init__(self, message_schema: Schema, sinks: [DataBusSinks]):
 
         self._STANDARD_OFFSET = 256
         self._latest_block = -1
-        self._queue: List[LogReceipt] = []
+        self._queue: deque = deque()
 
         logger.info('Data bus client initialized.')