qworker


Nameqworker JSON
Version 1.13.1 PyPI version JSON
download
home_pagehttps://github.com/phenobarbital/qworker
SummaryQueueWorker is asynchronous Task Queue implementation built on top of Asyncio.Can you spawn distributed workers to run functions inside workers.
upload_time2025-07-26 00:13:44
maintainerNone
docs_urlNone
authorJesus Lara
requires_python>=3.8.0
licenseMIT
keywords distributed objects workers asyncio task queue rpc remote method call
VCS
bugtrack_url
requirements No requirements were recorded.
Travis-CI No Travis.
coveralls test coverage No coveralls.
            # QueueWorker #

[![pypi](https://img.shields.io/pypi/v/asyncdb?style=plastic)](https://pypi.org/project/asyncdb/)
[![versions](https://img.shields.io/pypi/pyversions/blacksheep.svg?style=plastic)](https://github.com/phenobarbital/qworker)
[![MIT licensed](https://img.shields.io/github/license/phenobarbital/qworker?style=plastic)](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[![pypi](https://img.shields.io/pypi/v/asyncdb?style=plastic)](https://pypi.org/project/asyncdb/)\n[![versions](https://img.shields.io/pypi/pyversions/blacksheep.svg?style=plastic)](https://github.com/phenobarbital/qworker)\n[![MIT licensed](https://img.shields.io/github/license/phenobarbital/qworker?style=plastic)](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.1",
    "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": null,
            "digests": {
                "blake2b_256": "583980805f71493bcfd8f3401f65c2555c4d453683dcb1107943673687e3689f",
                "md5": "588c95c09340d072347dc9d4d7b9fe9a",
                "sha256": "b587e9450449991a6599ddf986a6a625dd72f4dfcdcca9702e746de041d1320b"
            },
            "downloads": -1,
            "filename": "qworker-1.13.1-cp310-cp310-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl",
            "has_sig": false,
            "md5_digest": "588c95c09340d072347dc9d4d7b9fe9a",
            "packagetype": "bdist_wheel",
            "python_version": "cp310",
            "requires_python": ">=3.8.0",
            "size": 444298,
            "upload_time": "2025-07-26T00:13:44",
            "upload_time_iso_8601": "2025-07-26T00:13:44.912422Z",
            "url": "https://files.pythonhosted.org/packages/58/39/80805f71493bcfd8f3401f65c2555c4d453683dcb1107943673687e3689f/qworker-1.13.1-cp310-cp310-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl",
            "yanked": false,
            "yanked_reason": null
        },
        {
            "comment_text": null,
            "digests": {
                "blake2b_256": "42b92a8391aea71812fdc4d6da63b78861909ec850378b9c2a2f10c0ad3ad8fe",
                "md5": "f800b48c8c43a700225cbc173b5b012c",
                "sha256": "4510c198155fd226414b7c6936b12d40d374b5c6c3c40c08d15034537af41553"
            },
            "downloads": -1,
            "filename": "qworker-1.13.1-cp311-cp311-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl",
            "has_sig": false,
            "md5_digest": "f800b48c8c43a700225cbc173b5b012c",
            "packagetype": "bdist_wheel",
            "python_version": "cp311",
            "requires_python": ">=3.8.0",
            "size": 477923,
            "upload_time": "2025-07-26T00:13:46",
            "upload_time_iso_8601": "2025-07-26T00:13:46.352570Z",
            "url": "https://files.pythonhosted.org/packages/42/b9/2a8391aea71812fdc4d6da63b78861909ec850378b9c2a2f10c0ad3ad8fe/qworker-1.13.1-cp311-cp311-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl",
            "yanked": false,
            "yanked_reason": null
        },
        {
            "comment_text": null,
            "digests": {
                "blake2b_256": "4da4e1c82b2480b6720c309dd4835ed64d172715c063b20140400a056ac408b9",
                "md5": "22f7dc3399b0258f09f9d057fd54df0d",
                "sha256": "c5f7f37193ed1c7bdd191790a9b52caa5a52f55669c93a52beaf2036459c1f53"
            },
            "downloads": -1,
            "filename": "qworker-1.13.1-cp312-cp312-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl",
            "has_sig": false,
            "md5_digest": "22f7dc3399b0258f09f9d057fd54df0d",
            "packagetype": "bdist_wheel",
            "python_version": "cp312",
            "requires_python": ">=3.8.0",
            "size": 515184,
            "upload_time": "2025-07-26T00:13:47",
            "upload_time_iso_8601": "2025-07-26T00:13:47.955080Z",
            "url": "https://files.pythonhosted.org/packages/4d/a4/e1c82b2480b6720c309dd4835ed64d172715c063b20140400a056ac408b9/qworker-1.13.1-cp312-cp312-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl",
            "yanked": false,
            "yanked_reason": null
        },
        {
            "comment_text": null,
            "digests": {
                "blake2b_256": "baa595384205bb9c48bd5dac7af28ae12dc6c57e59fbe6e01efdd8fb53f3550d",
                "md5": "b3305d1e57a787515769bbb7bf9442b9",
                "sha256": "5d08c69c8d706bf15b9b83bbaec6a450eab90b2940c9720cc1869f9246405f4c"
            },
            "downloads": -1,
            "filename": "qworker-1.13.1-cp39-cp39-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl",
            "has_sig": false,
            "md5_digest": "b3305d1e57a787515769bbb7bf9442b9",
            "packagetype": "bdist_wheel",
            "python_version": "cp39",
            "requires_python": ">=3.8.0",
            "size": 449229,
            "upload_time": "2025-07-26T00:13:49",
            "upload_time_iso_8601": "2025-07-26T00:13:49.013541Z",
            "url": "https://files.pythonhosted.org/packages/ba/a5/95384205bb9c48bd5dac7af28ae12dc6c57e59fbe6e01efdd8fb53f3550d/qworker-1.13.1-cp39-cp39-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl",
            "yanked": false,
            "yanked_reason": null
        }
    ],
    "upload_time": "2025-07-26 00:13:44",
    "github": true,
    "gitlab": false,
    "bitbucket": false,
    "codeberg": false,
    "github_user": "phenobarbital",
    "github_project": "qworker",
    "travis_ci": false,
    "coveralls": false,
    "github_actions": true,
    "lcname": "qworker"
}
        
Elapsed time: 2.24125s