fakz9/Sipro-Stocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: buffer

Browse Source
This commit is contained in:
admin
2024-11-09 11:09:16 +03:00
parent e586a854b2
commit 8cb94d06bf
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
background/tasks.py
View File

@@ -37,6 +37,9 @@ async def flush_buffer():
product_ids = await buffer.get_tasks() product_ids = await buffer.get_tasks()
total_products = len(product_ids) total_products = len(product_ids)
if not product_ids:
logging.info('Buffer is empty')
return
logging.info(f'Flushing buffer with {total_products} products') logging.info(f'Flushing buffer with {total_products} products')
await process_update(product_ids) await process_update(product_ids)
logging.info(f'Buffer flushed with {total_products} products') logging.info(f'Buffer flushed with {total_products} products')