Skip to main content

Library that provides a system to generate tasks producers and consumers with ease.

Project description

build status coverage






José Antonio Perdiguero López

Library that provides a system to generate tasks producers and consumers with ease.

Celery is used as backend, so it’s necessary to configure it in the application where this library will be used.

To achieve a producer-consumer behavior this library provides an easy to use script for running all necessary processes:

  • Producer: Tasks in charge of generating processing units.

  • Consumer: Tasks that handle and run processing units.

  • Scheduler: Manager that runs producer tasks according to specified dates or regularity.

Quick start

  1. Install this package using pip:

pip install task-dispatcher
  1. Decorate your functions as producer and consumer tasks:

from task_dispatcher import consumer, producer

def square(x):
    return x**2

def prod_function(n):
    for i in range(n):
  1. Run producer, consumer and scheduler processes:

python task-dispatcher producer
python task-dispatcher consumer
python task-dispatcher scheduler

Consumer and Producer

This library provides convenient decorators for generating a task dispatcher system based on producer-consumer pattern. Decorated functions or methods acts as Celery tasks and can be called using his own syntax: Calling celery tasks. Also, it’s possible to compose these tasks using Celery Canvas.


Consumer and producer tasks are registered to ease the way of access them. There is a register module that contains the task register where all tasks can be found:

from task_dispatcher import register

# Get consumers

# Get produces

Also, this register provides a set of utilities, such as convert it into JSON or YAML format:

from task_dispatcher import register

yaml_register = register.to_yaml()
json_register = register.to_json()

Command Line Interface

There is a script that can be called directly through executing the task_dispatcher package itself or the command located in commands module. To show command help:

python task-dispatcher -h

This script also gives a friendly way of list all tasks registered:

python task-dispatcher list


This library can be imported and used as a Django application instead of a plain library, so that the CLI script also acts as a Django command.


Celery settings can be specified through TASK_DISPATCHER_SETTINGS variable using path format indicated in Celery application configuration.

Project details

Download files

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

Source Distribution

task-dispatcher-1.4.5.tar.gz (9.4 kB view hashes)

Uploaded source

Built Distribution

task_dispatcher-1.4.5-py2.py3-none-any.whl (13.7 kB view hashes)

Uploaded py2 py3

Supported by

AWS AWS Cloud computing Datadog Datadog Monitoring Fastly Fastly CDN Google Google Object Storage and Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page