Merge branch 'release/0.9.2'

.github/workflows/test.yml

@@ -8,10 +8,8 @@ jobs:
       matrix:
         cmd:
           - black
-          - flake8
-          - isort
+          - ruff
           - mypy
-          - autoflake
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v2

.gitignore

@@ -168,3 +168,6 @@ node_modules
 
 # macOS
 .DS_Store
+
+# Ruff
+.ruff_cache/

.pre-commit-config.yaml

@@ -12,7 +12,7 @@ repos:
   - repo: https://github.com/asottile/add-trailing-comma
     rev: v2.1.0
     hooks:
-    -   id: add-trailing-comma
+      - id: add-trailing-comma
 
   - repo: local
     hooks:
@@ -22,35 +22,19 @@ repos:
         language: system
         types: [python]
 
-      - id: autoflake
-        name: autoflake
-        entry: poetry run autoflake
-        language: system
-        types: [ python ]
-        args: [ --in-place, --remove-all-unused-imports, --remove-duplicate-keys ]
-
-      - id: isort
-        name: isort
-        entry: poetry run isort
-        language: system
-        types: [ python ]
-
-      - id: flake8
-        name: Check with Flake8
-        entry: poetry run flake8
+      - id: ruff
+        name: Run ruff lints
+        entry: poetry run ruff
         language: system
         pass_filenames: false
-        types: [ python ]
-        args: [--count, taskiq]
+        types: [python]
+        args:
+          - "--fix"
+          - "taskiq"
+          - "tests"
 
       - id: mypy
         name: Validate types with MyPy
         entry: poetry run mypy
         language: system
-        types: [ python ]
-
-      - id: yesqa
-        name: Remove usless noqa
-        entry: poetry run yesqa
-        language: system
-        types: [ python ]
+        types: [python]

docs/examples/dynamics/receiver.py

@@ -17,7 +17,7 @@ async def main() -> None:
         task_name="dyn_task",
     )
 
-    # now we can send it.
+    # Now we can send it.
     await dyn_task.kiq(x=1)
 
     await asyncio.sleep(2)

docs/examples/dynamics/scheduler.py

@@ -32,7 +32,7 @@ async def main() -> None:
     # We create scheduler after the task declaration,
     # so we don't have to wait a minute before it gets to the task.
     # However, defining a scheduler before the task declaration is also possible.
-    # but we have to wait till it gets to task execution for the second time.
+    # But we have to wait till it gets to task execution for the second time.
     worker_task = asyncio.create_task(run_receiver_task(dyn_broker))
     scheduler_task = asyncio.create_task(run_scheduler_task(dyn_scheduler))
 

docs/guide/dynamic-brokers.md

@@ -3,35 +3,31 @@ title: Dynamic Environments
 order: 9
 ---
 
-This article is for all the people who want to dynamically create brokers, register tasks, and run them inside their code. Or maybe implement more complex logic.
+This article is for people who want to:
 
-The Taskiq allows you to create broker instances in all parts of your application. You
-can register tasks dynamically and run them. But when tasks are created dynamically,
-the `taskiq worker` command won't be able to find them.
+* Create brokers dynamically.
+* Register tasks, and run them inside their code.
+* Implement more complex logic.
 
-To define tasks and assign them to broker, use `register_task` method.
+Taskiq allows you to set up broker instances throughout your application and register tasks for dynamic execution. However, tasks created this way won't be found by the `taskiq worker` command.
+
+To define tasks and assign them to a broker, use `register_task` method.
 
 @[code python](../examples/dynamics/broker.py)
 
-The problem with this code is that if we run the `taskiq worker` command, it won't be able
-to execute our tasks. Because lambdas are created within the `main` function and they
-are not visible outside of it.
+In this example, the task is defined using a lambda within the `main` function. As the lambda is not visible outside of the `main` function scope, the task is not executable by `taskiq worker` command.
+
+To overcome this issue, you can:
 
-To surpass this issue, we need to create a dynamic worker task within the current loop.
-Or, we can create a code that can listen to our brokers and have all information about dynamic
-functions.
+* Create a dynamic worker task within the current event loop.
+* Implement your own broker listener with the information about all of your tasks.
 
-Here I won't be showing how to create your own CLI command, but I'll show you how to create
-a dynamic worker within the current loop.
+Here's an example of a dynamic worker task creation:
 
 @[code python](../examples/dynamics/receiver.py)
 
-Here we define a dynamic lambda task with some name, assign it to broker, as we did before.
-The only difference is that we start our receiver coroutine, that will listen to the new
-messages and execute them. Receiver task will be executed in the current loop, and when main function
-exits, the receriver task is canceled. But for illustration purpose, I canceled it manually.
+In this example, a named dynamic lambda task is created and registered in a broker, similar to the previous example. The difference is the creation of a new receiver coroutine for the worker task. It will listen to the new messages and execute them. The worker task will be executed in the current event loop. After exiting the scope, the worker task will get cancelled. For illustration purposes it is cancelled explicitly.
 
-Sometimes you need to run not only receiver, but a scheduler as well. You can do it, by using
-another function that also can work within the current loop.
+It's possible to run a scheduler in the current event loop as well:
 
 @[code python](../examples/dynamics/scheduler.py)