From 90155aab4b46d6fdb04ad83405586855d092663b Mon Sep 17 00:00:00 2001 From: hweawer Date: Thu, 29 Aug 2024 09:27:35 +0200 Subject: [PATCH] Deq --- src/transport/msg_providers/data_bus.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/transport/msg_providers/data_bus.py b/src/transport/msg_providers/data_bus.py index 8e38b880..bf010695 100644 --- 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.')