Update batch_size=1000 to general.batch_size in cfg
This commit is contained in:
@@ -484,7 +484,7 @@ class PostgreSQLClient:
|
|||||||
storage = get_storage()
|
storage = get_storage()
|
||||||
|
|
||||||
# Получаем необработанные сообщения из SQLite
|
# Получаем необработанные сообщения из SQLite
|
||||||
unprocessed = storage.get_unprocessed_messages(limit=1000)
|
unprocessed = storage.get_unprocessed_messages(limit=config.general.batch_size)
|
||||||
if not unprocessed:
|
if not unprocessed:
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user