CODEWITHSUNDEEP
pythonpython-asyncio
ca9163d9
ca9163d9

Reputation: 29159

Call an async function periodically?

I have the following function to call s(c) every 24 hours.

def schedule_next_sync():
    t = datetime.datetime.now()
    t = t.replace(hour=0) + datetime.timedelta(hours=24)
    def wrapper():
        s(c)
        schedule_next_sync()
    tornado.ioloop.IOLoop.current().add_timeout(datetime.datetime.timestamp(t), wrapper)

However, s() will be changed to an async function.

async def s(c):

How to update schedule_next_sync for async function? Should run s() synchronously? Or change schedule_next_sync() to an async function?

Upvotes: 3

Views: 450

Answers (1)

user4815162342
user4815162342

Reputation: 154846

Once s is async, you could use asyncio.sleep() instead of the lower-level add_timeout():

async def schedule_next_sync():
    async def call_forever():
        while True:
            await asyncio.sleep(1)
            await s(c)
    tornado.ioloop.IOLoop.current().create_task(call_forever())

If you really want to do it with timeouts, something like this should work:

def schedule_next_sync():
    t = datetime.datetime.now() + datetime.timedelta(seconds=1)
    def wrapper():
        loop = asyncio.get_running_loop()
        task = loop.create_task(s(c))
        task.add_done_callback(lambda _: schedule_next_sync())
    loop = tornado.ioloop.IOLoop.current()
    loop.add_timeout(datetime.datetime.timestamp(t), wrapper)

Upvotes: 1

Related Questions