gelbpunkt / aioscheduler Goto Github PK

This problem appears only when using TimedScheduler.

After tasks have been executed they stay in event loop till the end of program, which can be critical for overall perfomance.

Here is minimal code to reproduce that bug:

async def task(num):
    print(f'Num: {num}')

async def main():
    scheduler = aioscheduler.TimedScheduler(10)

    for i in range(10):
        scheduler.schedule(task(i), datetime.datetime.utcnow() + datetime.timedelta(seconds=i + 3))

    scheduler.start()

    while True:
        print(len(asyncio.all_tasks()))  # Getting count of currently running tasks in main event loop
        await asyncio.sleep(1)

asyncio.run(main())

Expected behavior
Here is a code example without scheduler, using only asyncio.create_task function:

async def task(num):
    await asyncio.sleep(num)
    print(f'Num: {num}')

async def main():

    for i in range(10):
        asyncio.create_task(task(i))

    while True:
        print(len(asyncio.all_tasks()))
        await asyncio.sleep(1)

asyncio.run(main())

At first it shows 11 active tasks (1 for main function and 10 for custom tasks I added). But gradually as tasks run this number decreases back to 1.

This is not the case for aioscheduler scheduler where tasks somewhy remain active even after function finishes.

Library and Python version

• Library: 1.4.2 (latest)
• Python: 3.10.6

I'll try to fix this bug myself and create pull request, but in any case this bug should be fixed ASAP

So I have a function in my bot class which a subclass of AutoShardedBot and the function is remove_role_task

When I try to start a job from a cog using schedule method and the coro is like bot.remove_role_task the task never starts. And when I check the tasks of the scheduler its empty. But when I create the same method in the cog itself the task starts and executes in time.

I have been using this library for a long time but looks like it does not work in Python3.11, tasks are never executed. And no error is also printed on the console

but when I stop the application it just says x is never awaited error.

Just use the example on Readme. It will not work on 3.11 but work on 3.10