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: README.md
+3-4Lines changed: 3 additions & 4 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -78,16 +78,15 @@ FluxQueue supports async functions too. Just define an async function and use th
78
78
@fluxqueue.task()
79
79
asyncdefprocess_data(data: dict):
80
80
# Your async processing logic
81
-
result =await some_async_operation(data)
82
-
return result
81
+
await some_async_operation(data)
83
82
84
83
# Enqueue it (use await in async contexts)
85
84
await process_data({"key": "value"})
86
85
```
87
86
88
87
## Installing the worker
89
88
90
-
In order the tasks to be executed you need to run a fluxqueue worker, you need to install the worker on your system with:
89
+
In order the tasks to be executed you need to run a FluxQueue worker, you need to install the worker on your system with:
91
90
92
91
```bash
93
92
fluxqueue worker install
@@ -103,7 +102,7 @@ Running the worker is straightforward:
103
102
fluxqueue start --tasks-module-path myapp/tasks
104
103
```
105
104
106
-
In order the worker to disover your tasks you need to pass `--tasks-module-path` argument with the path to the tasks module. For more information please view the [documentation](https://fluxqueue.ccxlv.dev/tutorial/defininig_and_exposing_tasks).
105
+
In order the worker to disover your tasks you need to pass `--tasks-module-path` argument with the path to the tasks module. For more information please view the [Defining and Exposing Tasks](https://fluxqueue.ccxlv.dev/tutorial/defininig_and_exposing_tasks) documentation.
0 commit comments