# 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": "",
"docs_url": null,
"requires_python": ">=3.8.0",
"maintainer_email": "",
"keywords": "distributed objects,workers,asyncio,task queue,RPC,remote method call",
"author": "Jesus Lara",
"author_email": "jesuslara@phenobarbital.info",
"download_url": "",
"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.9.21",
"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": "9d07e9306b80f47194ab7cf54ecc4ac4afcf570c7b9e47682bf050e2758d85c9",
"md5": "aff4d73c167bd82ce1a32721719f57fd",
"sha256": "c57d9436051c14ea029c90c3e84877ea4e9bf2d30924122e07da0fa17476d48e"
},
"downloads": -1,
"filename": "qworker-1.9.21-cp310-cp310-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "aff4d73c167bd82ce1a32721719f57fd",
"packagetype": "bdist_wheel",
"python_version": "cp310",
"requires_python": ">=3.8.0",
"size": 326140,
"upload_time": "2023-11-02T14:42:47",
"upload_time_iso_8601": "2023-11-02T14:42:47.880165Z",
"url": "https://files.pythonhosted.org/packages/9d/07/e9306b80f47194ab7cf54ecc4ac4afcf570c7b9e47682bf050e2758d85c9/qworker-1.9.21-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": "6dc89ac1805d4fd4545bc49c74b8d873889a6251554f66475ad4e979841d7b15",
"md5": "516a9e74abcb1e8b85cfcb97072289f3",
"sha256": "74235337bea842b9f087da3a15709f49d5319b0ed15220e64c158e2353f901b3"
},
"downloads": -1,
"filename": "qworker-1.9.21-cp311-cp311-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "516a9e74abcb1e8b85cfcb97072289f3",
"packagetype": "bdist_wheel",
"python_version": "cp311",
"requires_python": ">=3.8.0",
"size": 337336,
"upload_time": "2023-11-02T14:42:50",
"upload_time_iso_8601": "2023-11-02T14:42:50.037713Z",
"url": "https://files.pythonhosted.org/packages/6d/c8/9ac1805d4fd4545bc49c74b8d873889a6251554f66475ad4e979841d7b15/qworker-1.9.21-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": "11228c8c1e29db1b41da81bf954c3ef05c2c9f1d5db2c31caf73af65f594c3eb",
"md5": "2e6f763511cbf79d049c9935f82ccd51",
"sha256": "99644f1364c34ec906d261528a498ac8d20208c67b56024ae0f139990065ca4b"
},
"downloads": -1,
"filename": "qworker-1.9.21-cp38-cp38-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "2e6f763511cbf79d049c9935f82ccd51",
"packagetype": "bdist_wheel",
"python_version": "cp38",
"requires_python": ">=3.8.0",
"size": 331260,
"upload_time": "2023-11-02T14:42:51",
"upload_time_iso_8601": "2023-11-02T14:42:51.724064Z",
"url": "https://files.pythonhosted.org/packages/11/22/8c8c1e29db1b41da81bf954c3ef05c2c9f1d5db2c31caf73af65f594c3eb/qworker-1.9.21-cp38-cp38-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": "cf60790a9fdc42e28dac2646d524ec0933b8239ebd1714749404362edc62bf18",
"md5": "2e70bf27f9f96bc27059b03f08d0b59b",
"sha256": "b0afd9c9234ba72ef9a52c5401051156fcc8b06ab54df85af8b8a776167cb605"
},
"downloads": -1,
"filename": "qworker-1.9.21-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_17_x86_64.manylinux2014_x86_64.whl",
"has_sig": false,
"md5_digest": "2e70bf27f9f96bc27059b03f08d0b59b",
"packagetype": "bdist_wheel",
"python_version": "cp39",
"requires_python": ">=3.8.0",
"size": 321528,
"upload_time": "2023-11-02T14:42:52",
"upload_time_iso_8601": "2023-11-02T14:42:52.904723Z",
"url": "https://files.pythonhosted.org/packages/cf/60/790a9fdc42e28dac2646d524ec0933b8239ebd1714749404362edc62bf18/qworker-1.9.21-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": "2023-11-02 14:42:47",
"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
