diff --git a/can_sniffer/src/postgresql_handler/postgresql_client.py b/can_sniffer/src/postgresql_handler/postgresql_client.py index 2ca009f..a6d0c58 100644 --- a/can_sniffer/src/postgresql_handler/postgresql_client.py +++ b/can_sniffer/src/postgresql_handler/postgresql_client.py @@ -484,7 +484,7 @@ class PostgreSQLClient: storage = get_storage() # Получаем необработанные сообщения из SQLite - unprocessed = storage.get_unprocessed_messages(limit=1000) + unprocessed = storage.get_unprocessed_messages(limit=config.general.batch_size) if not unprocessed: return 0