feat: non-blocking tasks

[Sobes76rus]

non-blocking sleep through a temporary increase in the number of running tasks on demand of the user.
here is some use cases

1. some task A is waiting for result of another task B. User can request a temporary increase in the number of tasks, so this task A does not block the execution of task B because of max_async_tasks. Example in tests with max_async_tasks = 1
2. i have a real case scenario where very long running tasks sleeps for a very long time and there is a need to keep their scope, so i increase the max number of running tasks while they asleep

[codecov-commenter]

Codecov Report

Merging #128 (a460da4) into develop (e66f3aa) will increase coverage by 4.98%.
The diff coverage is 82.40%.

❗ Your organization is not using the GitHub App Integration. As a result you may experience degraded service beginning May 15th. Please install the Github App Integration for your organization. Read more.

@@ Coverage Diff @@## develop #128 +/- ## =========================================== + Coverage 67.62% 72.60% +4.98%  =========================================== Files 37 43 +6 Lines 942 1387 +445 =========================================== + Hits 637 1007 +370 - Misses 305 380 +75 

Impacted Files	Coverage Δ
taskiq/abc/middleware.py	100.00% <ø> (ø)
taskiq/abc/result_backend.py	100.00% <ø> (ø)
taskiq/cli/scheduler/run.py	0.00% <ø> (ø)
taskiq/cli/watcher.py	0.00% <ø> (ø)
taskiq/cli/worker/log_collector.py	100.00% <ø> (ø)
taskiq/cli/worker/process_manager.py	0.00% <0.00%> (ø)
taskiq/cli/worker/run.py	0.00% <0.00%> (ø)
taskiq/events.py	100.00% <ø> (ø)
taskiq/receiver/params_parser.py	96.87% <ø> (ø)
taskiq/result_backends/dummy.py	100.00% <ø> (ø)
... and 24 more

... and 1 file with indirect coverage changes

📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more

[lembregtse]

@s3rius are there plans to have this merged / or implemented differently? We have a use-case as well that triggers this that we noticed since we have now implemented the max_async_tasks option.

We will "workarround" by separating them into two different workers for now.

[s3rius]

There are plans to implement it differently. There were some attempts.

The main idea of another approach is to not give just a sleep function, but an ability to decrease counter of running tasks by the time of executing a function.

I've created an issue for that problem here: #258.

The problem with this approach is that in most cases we don't use sleep directly, but awaiting something.

[Sobes76rus]

Hello there @s3rius ! I changed approach to dealing with idle tasks
Now u can do smth like this

async def task(idle: TaskIdler = Depends()): async with idle(): await smth() 

Pls take a look

ps: there are some endless action going on. pls stop it

[Sobes76rus]

Hello, @s3rius. Pls take a look at the new implementation

[Sobes76rus]

@s3rius A friendly reminder to check this PR :D

[Sobes76rus]

Hello there @s3rius! Pls give it a try =)