QueueWorker is asynchronous Task Queue implementation built on top of Asyncio.Can you spawn distributed workers to run functions inside workers.


Keywords
distributed, objects, workers, asyncio, task, queue, RPC, remote, method, call
License
MIT
Install
pip install qworker==1.10.3

Documentation

QueueWorker

pypi versions MIT licensed

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 --port --worker

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.