Skip to main content

Async task queue for Python

Project description

atq is a pure-Python asynchronous task queue built to work with asyncio. It is designed to run costly functions outside main event loop using distributed workers.

atq requires Python 3.5+ and is distributed under BSD license.


First, you should start workers on the servers you plan to use for task execution

atqserver --host <hostname> --port <port-number> --worker <num-workers>


  • <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

Please note that code of tasks should be accessible by atq, so it’s advised to run atq server from your project root directory in more complex situations.

Then you will need to create a client using hostnames and ports of initialized servers:

import atq

q = atq.Q([
     ("localhost", 12345),

Finally you can use atq in your code:

import atq
import asyncio
import requests
from collections import ChainMap
from collections import Counter

URLS = [

q = atq.Q([
    ("localhost", 12345),

def top_words(url, n):
    """Returns top n words from text specified by url."""
    text = requests.get(url).text.split()
    return {url: Counter(text).most_common(n)}

async def get_top_words(urls, n):
    """Returns top n words in documents specified by URLs."""
    tops_in_url = await asyncio.gather(
        *[q.q(top_words, url, n) for url in urls])
    return ChainMap(*tops_in_url)

top = asyncio.get_event_loop().run_until_complete(get_top_words(URLS, 10))

You can find more examples in examples subdirectory.


pip3 install atq


python3 test



Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for atq, version 0.0.2
Filename, size File type Python version Upload date Hashes
Filename, size atq-0.0.2-py3-none-any.whl (8.0 kB) File type Wheel Python version py3 Upload date Hashes View

Supported by

AWS AWS Cloud computing Datadog Datadog Monitoring DigiCert DigiCert EV certificate Facebook / Instagram Facebook / Instagram PSF Sponsor Fastly Fastly CDN Google Google Object Storage and Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Salesforce Salesforce PSF Sponsor Sentry Sentry Error logging StatusPage StatusPage Status page