You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: docs/available-components/middlewares.md
+5-5Lines changed: 5 additions & 5 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -7,7 +7,7 @@ order: 5
7
7
Middlewares allow you to execute code when specific event occurs.
8
8
Taskiq has several default middlewares.
9
9
10
-
###Simple retry middleware
10
+
## Simple retry middleware
11
11
12
12
This middleware allows you to restart functions on errors. If exception was raised during task execution,
13
13
the task would be resent with same parameters.
@@ -34,11 +34,11 @@ async def test():
34
34
35
35
`retry_on_error` enables retries for a task. `max_retries` is the maximum number of times,.
36
36
37
-
## Smart Retry Middleware
37
+
## Smart retry middleware
38
38
39
39
The `SmartRetryMiddleware` automatically retries tasks with flexible delay settings and retry strategies when errors occur. This is particularly useful when tasks fail due to temporary issues, such as network errors or temporary unavailability of external services.
40
40
41
-
### Key Features:
41
+
### Key Features
42
42
43
43
***Retry Limits**: Set the maximum number of retry attempts (`max_retries`).
44
44
***Delay Before Retry**: Define a fixed delay or use additional strategies.
@@ -85,7 +85,7 @@ Use jitter and exponential backoff to avoid repetitive load peaks, especially in
85
85
86
86
87
87
88
-
###Prometheus middleware
88
+
## Prometheus middleware
89
89
90
90
You can enable prometheus metrics for workers by adding `PrometheusMiddleware`.
91
91
To do so, you need to install `prometheus_client` package or you can install metrics extras for taskiq.
Copy file name to clipboardExpand all lines: docs/framework_integrations/faststream.md
+2-2Lines changed: 2 additions & 2 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -4,7 +4,7 @@ order: 3
4
4
5
5
# Taskiq + FastStream
6
6
7
-
[FastStream](https://faststream.airt.ai/latest/) is a library that allows you to write consumers and producers for different message brokers almost like taskiq. But the difference is that taskiq is more focused on tasks for a specific project and more like celery but async, while FastStream is more focused on events and defining how different systems communicate with each other using distributed brokers.
7
+
[FastStream](https://faststream.ag2.ai/latest/) is a library that allows you to write consumers and producers for different message brokers almost like taskiq. But the difference is that taskiq is more focused on tasks for a specific project and more like celery but async, while FastStream is more focused on events and defining how different systems communicate with each other using distributed brokers.
8
8
9
9
If you want to declare communication between different projects you can use taskiq, but it might be a bit more complex than using FastStream.
10
10
@@ -29,4 +29,4 @@ app = FastStream(broker)
29
29
taskiq_broker = BrokerWrapper(broker)
30
30
```
31
31
32
-
You can read more about scheduling tasks for FastStream in the [FastStream documentation](https://faststream.airt.ai/latest/scheduling/?h=schedule).
32
+
You can read more about scheduling tasks for FastStream in the [FastStream documentation](https://faststream.ag2.ai/latest/scheduling/?h=schedule).
0 commit comments