thecoffemaker/Slixfeed
1
0
Fork 0
forked from sch/Slixfeed
Code Pull requests Activity

Laura: Fix awaitable error 4d03d6e16e

Browse source
This commit is contained in:
Schimon Jehudah 2023-12-28 17:58:49 +00:00
parent b2387a700d
commit 7ee4000ee0
1 changed files with 13 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
slixfeed/task.py
View file

@ -361,11 +361,14 @@ async def refresh_task(self, jid, callback, key, val=None):
task_manager[jid][key].cancel()
except:
print("No task of type", key, "to cancel for JID", jid)
task_manager[jid][key] = loop.call_at(
loop.time() + 60 * float(val),
loop.create_task,
(callback(self, jid))
# send_update(jid)
# task_manager[jid][key] = loop.call_at(
# loop.time() + 60 * float(val),
# loop.create_task,
# (callback(self, jid))
# # send_update(jid)
# )
task_manager[jid][key] = loop.create_task(
wait_and_run(self, callback, jid, val)
)
# task_manager[jid][key] = loop.call_later(
# 60 * float(val),
@ -379,6 +382,11 @@ async def refresh_task(self, jid, callback, key, val=None):
# )
async def wait_and_run(self, callback, jid, val):
await asyncio.sleep(60 * float(val))
await callback(self, jid)
# TODO Take this function out of
# <class 'slixmpp.clientxmpp.ClientXMPP'>
async def check_updates(jid):