Per-job timeout?

[Arseniy-Popov]

Would you consider adding a per-job timeout? How long a job is allowed to remain in the active state. This library seems like the place to put it.

[Dreamsorcerer]

I don't think there's any timeout here, is there? To create a timeout for a particular job, just wrap the task in a timeout.

At the very simplest, I think you can just pass asyncio.wait_for(my_task(), timeout), instead of my_task() directly.