# 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.13.0",
"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": "3da28d98dd15c5a7977ba08a2e32ce59ead8d4026c5dee3ccc7a16accd7cf65f",
"md5": "54c600b590621a7bcff4b95e0573c347",
"sha256": "1d1f03f15cab6771d417bedfb963cd2be7150acd671ae7d97f4b05b869565139"
},
"downloads": -1,
"filename": "qworker-1.13.0-cp310-cp310-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "54c600b590621a7bcff4b95e0573c347",
"packagetype": "bdist_wheel",
"python_version": "cp310",
"requires_python": ">=3.8.0",
"size": 443906,
"upload_time": "2024-11-24T02:06:57",
"upload_time_iso_8601": "2024-11-24T02:06:57.116579Z",
"url": "https://files.pythonhosted.org/packages/3d/a2/8d98dd15c5a7977ba08a2e32ce59ead8d4026c5dee3ccc7a16accd7cf65f/qworker-1.13.0-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": "9ed82d45914795d855e789f41cf6007c96dafeafe8dce0d4a0d30de06eb03078",
"md5": "743b9c9f7d6532466aefa1e3cabcca03",
"sha256": "468f2d62f1a744d67775de5a7862c57d9ff59269cfd54fbb50144e612cc5645b"
},
"downloads": -1,
"filename": "qworker-1.13.0-cp311-cp311-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "743b9c9f7d6532466aefa1e3cabcca03",
"packagetype": "bdist_wheel",
"python_version": "cp311",
"requires_python": ">=3.8.0",
"size": 477530,
"upload_time": "2024-11-24T02:06:59",
"upload_time_iso_8601": "2024-11-24T02:06:59.043403Z",
"url": "https://files.pythonhosted.org/packages/9e/d8/2d45914795d855e789f41cf6007c96dafeafe8dce0d4a0d30de06eb03078/qworker-1.13.0-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": "5dee8f9d0af0b9981f99af25f1d3d816115ccbcc7364bef4b72986a805fdff4d",
"md5": "2732a3e58324b8404829e2518e6bdeca",
"sha256": "28b686d099a52586a0217ea34d774947f89e92be838fb8aafaa3fc6199d96840"
},
"downloads": -1,
"filename": "qworker-1.13.0-cp312-cp312-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "2732a3e58324b8404829e2518e6bdeca",
"packagetype": "bdist_wheel",
"python_version": "cp312",
"requires_python": ">=3.8.0",
"size": 514790,
"upload_time": "2024-11-24T02:07:00",
"upload_time_iso_8601": "2024-11-24T02:07:00.858009Z",
"url": "https://files.pythonhosted.org/packages/5d/ee/8f9d0af0b9981f99af25f1d3d816115ccbcc7364bef4b72986a805fdff4d/qworker-1.13.0-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": "afe5e851ec4547029d61b31953fd076cf4f0a19fdd1176d5d95140c661dd8d91",
"md5": "e1353274e465005bca14898790a8fb8e",
"sha256": "c79a7703832d297aa9d4acc5ce891a0ae2aae48f39b0f6e2d55933d953efa1d9"
},
"downloads": -1,
"filename": "qworker-1.13.0-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "e1353274e465005bca14898790a8fb8e",
"packagetype": "bdist_wheel",
"python_version": "cp39",
"requires_python": ">=3.8.0",
"size": 448837,
"upload_time": "2024-11-24T02:07:02",
"upload_time_iso_8601": "2024-11-24T02:07:02.594263Z",
"url": "https://files.pythonhosted.org/packages/af/e5/e851ec4547029d61b31953fd076cf4f0a19fdd1176d5d95140c661dd8d91/qworker-1.13.0-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-24 02:06:57",
"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
