ICIJ's async worker library 
Installation
With AMQP:
pip install icij-worker["amqp"]
With neo4j:
pip install icij-worker["neo4j"]
Usage
Create an async app and register tasks
Create asynchronous task tailored for long running Python functions:
Given the following pure Python function inside the app.py module:
def long_running_task(greeted: str) -> str:
greeting = f"Hello {greeted} !"
return greeting
decorate your function with ICIJApp class and register a new task:
from icij_worker import AsyncApp
my_app = AsyncApp(name="my_app")
@my_app.task
def long_running_task(greeted: str) -> str:
greeting = f"Hello {greeted} !"
return greeting
this will register the long_running_task function under the long_running_task task name.
Optionally add progress handlers for a better task monitoring:
@my_app.task
async def long_running_task(
greeted: str,
progress: Optional[Callable[[float], Awaitable]] = None
) -> str:
if progress is not None:
await progress(0.0)
greeting = f"Hello {greeted} !"
if progress is not None:
await progress(100.0)
return greeting
Launch a async worker pool
Start a worker pool using:
icij-worker workers start "app.my_app"
provide worker pool options using:
icij-worker workers start -c worker_config.json -n 2 --backend multiprocessing "app.my_app"
depending on the worker configuration additional setup might be required.
Async worker implementations
Worker asynchronous backends
Implemented
- multiprocessing for CPU bound tasks
To be implemented
- asyncio for I/O bound tasks
4 maintainers
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file icij_worker-0.20.2.tar.gz.
File metadata
- Download URL: icij_worker-0.20.2.tar.gz
- Upload date:
- Size: 59.8 kB
- Tags: Source
- Uploaded using Trusted Publishing? Yes
- Uploaded via:
uv/0.6.7
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
cba6899fca55cc23cce56ebe2b970b74638f10572f420add09cc3b6043249212
|
|
| MD5 |
d4f0b9b70bf20b19eda8c09a77b43f52
|
|
| BLAKE2b-256 |
4ad2b267cb1de2f1d9023e820bd64383eae95fbc018d857e60c5d2229c074aa6
|
File details
Details for the file icij_worker-0.20.2-py3-none-any.whl.
File metadata
- Download URL: icij_worker-0.20.2-py3-none-any.whl
- Upload date:
- Size: 85.3 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? Yes
- Uploaded via:
uv/0.6.7
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
b1f6015c3bff7e4092dbb7ae208c4a77d6c6635f9aa4b46c4da784db7ccd879d
|
|
| MD5 |
c90d3f1c30cb5e9589241e94fea9b170
|
|
| BLAKE2b-256 |
927e7ccabd5a27443dd5d623c4989b978430d077c5a6ce304ac4a35e27f7c48f
|
