File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -78,12 +78,18 @@ taskiq_broker.task(
78
78
)
79
79
80
80
# create scheduler object
81
- scheduler= TaskiqScheduler(
81
+ scheduler = TaskiqScheduler(
82
82
broker = taskiq_broker,
83
83
sources = [LabelScheduleSource(taskiq_broker)],
84
84
)
85
85
```
86
86
87
+ To run the scheduler, just use the following command
88
+
89
+ ``` bash
90
+ taskiq scheduler module:scheduler
91
+ ```
92
+
87
93
Also, you can wrap your ** FastStream** application the same way (allows to use lifespan events and AsyncAPI documentation):
88
94
89
95
``` python
@@ -105,7 +111,7 @@ taskiq_broker = AppWrapper(app)
105
111
# Code below omitted 👇
106
112
```
107
113
108
- Also, instead of using a final ` message ` argument, you can set a message callback to collect information right before sending:
114
+ A little feature: instead of using a final ` message ` argument, you can set a message callback to collect information right before sending:
109
115
110
116
``` python
111
117
async def collect_information_to_send ():
You can’t perform that action at this time.
0 commit comments