# QueueWorker #
[](https://pypi.org/project/asyncdb/)
[](https://github.com/phenobarbital/qworker)
[](https://raw.githubusercontent.com/phenobarbital/qworker/master/LICENSE)
QueueWorker is asynchronous Task Queue implementation built to
work with ``asyncio``.
Can you spawn distributed workers to run functions inside workers and outside of
event loop.
``QueueWorker`` requires Python 3.8+ and is distributed under MIT license.
### How do I get set up? ###
First, you need to instal QueueWorker:
.. code-block ::
pip install qworker
Then, you can start several workers (even sharing the same port):
.. code-block ::
qw --host <hostname> --port <port-number> --worker <num-workers>
where
- ``<hostname>`` is a hostname of the server
- ``<port-number>`` is a port that server will listen on
- ``<num-workers>`` is a number of worker processes
### License ###
QueueWorker is copyright of Jesus Lara (https://phenobarbital.info) and is under MIT license. I am providing code in this repository under an open source license, remember, this is my personal repository; the license that you receive is from me and not from my employeer.
Raw data
{
"_id": null,
"home_page": "https://github.com/phenobarbital/qworker",
"name": "qworker",
"maintainer": null,
"docs_url": null,
"requires_python": ">=3.8.0",
"maintainer_email": null,
"keywords": "distributed objects, workers, asyncio, task queue, RPC, remote method call",
"author": "Jesus Lara",
"author_email": "jesuslara@phenobarbital.info",
"download_url": null,
"platform": null,
"description": "# QueueWorker #\n\n[](https://pypi.org/project/asyncdb/)\n[](https://github.com/phenobarbital/qworker)\n[](https://raw.githubusercontent.com/phenobarbital/qworker/master/LICENSE)\n\n\nQueueWorker is asynchronous Task Queue implementation built to\nwork with ``asyncio``.\nCan you spawn distributed workers to run functions inside workers and outside of\nevent loop.\n\n``QueueWorker`` requires Python 3.8+ and is distributed under MIT license.\n\n### How do I get set up? ###\n\nFirst, you need to instal QueueWorker:\n\n.. code-block ::\n\n pip install qworker\n\nThen, you can start several workers (even sharing the same port):\n\n.. code-block ::\n\n qw --host <hostname> --port <port-number> --worker <num-workers>\n\nwhere\n\n- ``<hostname>`` is a hostname of the server\n- ``<port-number>`` is a port that server will listen on\n- ``<num-workers>`` is a number of worker processes\n\n\n### License ###\n\nQueueWorker is copyright of Jesus Lara (https://phenobarbital.info) and is under MIT license. I am providing code in this repository under an open source license, remember, this is my personal repository; the license that you receive is from me and not from my employeer.\n",
"bugtrack_url": null,
"license": "MIT",
"summary": "QueueWorker is asynchronous Task Queue implementation built on top of Asyncio.Can you spawn distributed workers to run functions inside workers.",
"version": "1.12.7",
"project_urls": {
"Funding": "https://paypal.me/phenobarbital",
"Homepage": "https://github.com/phenobarbital/qworker",
"Say Thanks!": "https://saythanks.io/to/phenobarbital",
"Source": "https://github.com/phenobarbital/qworker"
},
"split_keywords": [
"distributed objects",
" workers",
" asyncio",
" task queue",
" rpc",
" remote method call"
],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "da7aa5dc955ff3e20e218eeb1ae3b7c1fe6aca77d4ecd74068835835e55bbd62",
"md5": "c338fb7fbbc9fbc2ec8d669c28db610a",
"sha256": "979739ef0460a066df6db5d309433b0acd9d373ec06404629f61ca2f7a88b7f6"
},
"downloads": -1,
"filename": "qworker-1.12.7-cp310-cp310-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "c338fb7fbbc9fbc2ec8d669c28db610a",
"packagetype": "bdist_wheel",
"python_version": "cp310",
"requires_python": ">=3.8.0",
"size": 434547,
"upload_time": "2024-11-03T23:31:28",
"upload_time_iso_8601": "2024-11-03T23:31:28.780347Z",
"url": "https://files.pythonhosted.org/packages/da/7a/a5dc955ff3e20e218eeb1ae3b7c1fe6aca77d4ecd74068835835e55bbd62/qworker-1.12.7-cp310-cp310-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "f782a80542c7899d073792d2650b3fc9b6fc058e16a19bec0ee7bfe70f15ed39",
"md5": "5008826fe01c5ba4b4e7bbcc733287d9",
"sha256": "241296dcd4831bf5dcbfb45471257397c56eaaf56e298b55d3d8a8c25aa44610"
},
"downloads": -1,
"filename": "qworker-1.12.7-cp311-cp311-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "5008826fe01c5ba4b4e7bbcc733287d9",
"packagetype": "bdist_wheel",
"python_version": "cp311",
"requires_python": ">=3.8.0",
"size": 468169,
"upload_time": "2024-11-03T23:31:30",
"upload_time_iso_8601": "2024-11-03T23:31:30.790649Z",
"url": "https://files.pythonhosted.org/packages/f7/82/a80542c7899d073792d2650b3fc9b6fc058e16a19bec0ee7bfe70f15ed39/qworker-1.12.7-cp311-cp311-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "9c4502e633c770260716a0b7d2f874e67a1ec227e5ef58d62a54ad3317795760",
"md5": "7775f1a87150e6206548f81f5c07553d",
"sha256": "919fce9a255a987d7809e862dbecee5d8c869324d97a08374f93f16b620648d3"
},
"downloads": -1,
"filename": "qworker-1.12.7-cp312-cp312-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "7775f1a87150e6206548f81f5c07553d",
"packagetype": "bdist_wheel",
"python_version": "cp312",
"requires_python": ">=3.8.0",
"size": 505433,
"upload_time": "2024-11-03T23:31:32",
"upload_time_iso_8601": "2024-11-03T23:31:32.290718Z",
"url": "https://files.pythonhosted.org/packages/9c/45/02e633c770260716a0b7d2f874e67a1ec227e5ef58d62a54ad3317795760/qworker-1.12.7-cp312-cp312-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "9a20659ff7f4fb8d9f6882cc9178d9d8c8f0f36f529e76669bd85c5d85472d05",
"md5": "780ef049b807bf4f8a79f8b551679864",
"sha256": "441cbe354f3963336a11d81136a99dbe1930f30aba210edc6ac5a80f3e92d70c"
},
"downloads": -1,
"filename": "qworker-1.12.7-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "780ef049b807bf4f8a79f8b551679864",
"packagetype": "bdist_wheel",
"python_version": "cp39",
"requires_python": ">=3.8.0",
"size": 439477,
"upload_time": "2024-11-03T23:31:33",
"upload_time_iso_8601": "2024-11-03T23:31:33.787989Z",
"url": "https://files.pythonhosted.org/packages/9a/20/659ff7f4fb8d9f6882cc9178d9d8c8f0f36f529e76669bd85c5d85472d05/qworker-1.12.7-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2024-11-03 23:31:28",
"github": true,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"github_user": "phenobarbital",
"github_project": "qworker",
"travis_ci": false,
"coveralls": false,
"github_actions": true,
"lcname": "qworker"
}
JSON
