No project description provided
Project description
Stats
Python parallel task-queue with redis
Based on
- rq
- redis
- gevent
Environment variables
PRQ_LOGS
- path to file with logs (512Mb data)
PipeLine
Every pipeline part use .wait()
to get result, if you want, it not block other task, task run in parallel.
Example to test
- Start worker
python prq.py --url redis://localhost:6379
(export python path before) 2. (a) Start pipeline (2 task)
python examples/pipeline/task_pipeline.py
- (b) Start another task in parallel execution
python examples/tasks/default_task.py
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
prq-0.0.21.tar.gz
(20.1 kB
view details)
Built Distribution
prq-0.0.21-py3-none-any.whl
(22.7 kB
view details)
File details
Details for the file prq-0.0.21.tar.gz
.
File metadata
- Download URL: prq-0.0.21.tar.gz
- Upload date:
- Size: 20.1 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/4.0.2 CPython/3.8.16
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 84ed3818b58a5b594752d7ee282c35270ec3ab9d95534e855a9223265979c70b |
|
MD5 | 089b59d33b68125b77cf092fb27ea531 |
|
BLAKE2b-256 | 7a1725f17db29cabbeab4774d837e9115138e96f8129f035ce40d59dbb7e3e0a |
File details
Details for the file prq-0.0.21-py3-none-any.whl
.
File metadata
- Download URL: prq-0.0.21-py3-none-any.whl
- Upload date:
- Size: 22.7 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/4.0.2 CPython/3.8.16
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 4ffa3b078a11f8a1e19e8d2d84d16258836850707cf0de25a97eac1164a9e2bf |
|
MD5 | b3d9a65b51c2bd1760b2a0186d001a87 |
|
BLAKE2b-256 | ee361c0de1c253c803db88cfcc7365ae2295bcd8c3fa3fb87fa8e230ff85fb3f |