highperfocused/lnbits
1
0
Fork 0
mirror of https://github.com/lnbits/lnbits.git synced 2025-09-18 11:31:41 +02:00
Code Issues Packages Projects Releases Wiki Activity

refactor: tasks should be run with internal wrapper

Browse Source 
listeners used did not use the helper function
This commit is contained in:
dni ⚡
2024-02-21 08:01:43 +01:00
committed by Pavol Rusnak
parent e419c74ebb
commit c88f05c5c0
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
lnbits/tasks.py
View File

@@ -87,7 +87,7 @@ async def internal_invoice_listener():
while True: while True:
checking_id = await internal_invoice_queue.get() checking_id = await internal_invoice_queue.get()
logger.info("> got internal payment notification", checking_id) logger.info("> got internal payment notification", checking_id)
asyncio.create_task(invoice_callback_dispatcher(checking_id)) create_task(invoice_callback_dispatcher(checking_id))
async def invoice_listener(): async def invoice_listener():
@@ -100,7 +100,7 @@ async def invoice_listener():
WALLET = get_wallet_class() WALLET = get_wallet_class()
async for checking_id in WALLET.paid_invoices_stream(): async for checking_id in WALLET.paid_invoices_stream():
logger.info("> got a payment notification", checking_id) logger.info("> got a payment notification", checking_id)
asyncio.create_task(invoice_callback_dispatcher(checking_id)) create_task(invoice_callback_dispatcher(checking_id))
async def check_pending_payments(): async def check_pending_payments():