How to run async func tasks?

[tehfink]

Adapting examples from the docs, the following doesn't seem to execute the async function:

from asyncz.schedulers.asyncio import AsyncIOScheduler
from asyncz.triggers import IntervalTrigger

scheduler = AsyncIOScheduler()
scheduler.start()

async def test_task():
    print("this is a test task!")

scheduler.add_task(
    fn=test_task,
    trigger=IntervalTrigger(seconds=2),
    max_instances=1,
    replace_existing=True,
    coalesce=True,
)
scheduler.process_tasks()
scheduler.shutdown()

[tarsil]

Hi @tehfink thank you for reporting this. Allow me some time to check and test on my side and I will come back to you.

[devkral]

It should work now. I added a specific test for it recently.