Skip to main content
Help us improve Python packaging – donate today!

A distributed task runner

Project Description

https://travis-ci.org/cenkalti/kuyruk.png https://coveralls.io/repos/cenkalti/kuyruk/badge.png?branch=master

Kuyruk is a simple and easy way of distributing tasks to run on servers.

It uses RabbitMQ as message broker and depends on Pika which is a pure-Python RabbitMQ client library.

How to install?

Kuyruk is available on PyPI.

$ pip install kuyruk

How to run tests?

Normally you don’t need this but it is easy. kuyruk/test directory contains files of both unit and integration tests. Make sure that RabbitMQ is running before running tests. Tests also run on Travis CI automatically on push.

$ git clone git://github.com/cenkalti/kuyruk.git
$ cd kuyruk
$ pip install -r kuyruk/test/requirements.txt
$ nosetests

How to define tasks?

Instantiate a Kuyruk object somewhere. Then just put a kuyruk.task decorator on top of your function that you want to run in background. After decorating, when you call the function it will send the task to default queue instead of running the function. Since Kuyruk does not support a result backend yet you should not be using the return value of the function.

from kuyruk import Kuyruk

kuyruk = Kuyruk()

@kuyruk.task
def echo(message):
    print message

# This will send a message to queue
echo('Hello, Kuyruk.')

How to run the worker?

Running the worker command with no parameters is enough for processing the tasks in the default queue.

$ kuyruk worker

Where is the documentation?

Here it is: http://kuyruk.readthedocs.org

Bitdeli badge

Release history Release notifications

History Node

9.0.7

History Node

9.0.6

History Node

9.0.5

History Node

9.0.4

History Node

9.0.3

History Node

9.0.2

History Node

8.5.1

History Node

8.5.0

History Node

8.4.0

History Node

8.3.2

History Node

8.3.1

History Node

8.3.0

History Node

8.2.0

History Node

8.1.1

History Node

8.1.0

History Node

8.0.0

History Node

7.0.1

History Node

7.0.0

History Node

6.0.2

History Node

6.0.1

History Node

6.0.0

History Node

5.1.2

History Node

5.1.1

History Node

5.1.0

History Node

5.0.4

History Node

5.0.3

History Node

5.0.2

History Node

5.0.1

History Node

4.1.2

History Node

4.1.1

History Node

4.1.0

History Node

4.0.7

History Node

4.0.6

History Node

4.0.5

History Node

4.0.4

History Node

4.0.3

History Node

4.0.2

History Node

4.0.1

History Node

4.0.0

History Node

3.4.0

History Node

3.3.0

History Node

3.2.0

History Node

3.1.0

History Node

3.0.0

History Node

2.0.2

History Node

2.0.1

History Node

2.0.0

History Node

1.2.4

History Node

1.2.3

History Node

1.2.1

History Node

1.2.0

History Node

1.1.0

History Node

1.0.1

History Node

1.0.0

History Node

0.24.3

History Node

0.24.2

This version
History Node

0.24.1

History Node

0.24.0

History Node

0.23.4

History Node

0.23.3

History Node

0.23.2

History Node

0.23.1

History Node

0.23.0

History Node

0.22.3

History Node

0.22.2

History Node

0.22.1

History Node

0.22.0

History Node

0.21.0

History Node

0.20.3

History Node

0.20.2

History Node

0.20.1

History Node

0.20.0

History Node

0.19.2

History Node

0.19.1

History Node

0.19.0

History Node

0.18.0

History Node

0.17.0

History Node

0.16.1

History Node

0.16.0

History Node

0.15.1

History Node

0.15.0

History Node

0.14.7

History Node

0.14.5

History Node

0.14.4

History Node

0.14.3

History Node

0.14.2

History Node

0.14.1

History Node

0.14.0

History Node

0.13.7

History Node

0.13.6

History Node

0.13.5

History Node

0.13.4

History Node

0.13.3

History Node

0.13.2

History Node

0.13.1

History Node

0.13.0

History Node

0.12.2

History Node

0.12.1

History Node

0.12.0

History Node

0.11.1

History Node

0.11.0

History Node

0.10.1

History Node

0.10.0

History Node

0.9.12

History Node

0.9.11

History Node

0.9.10

History Node

0.9.9

History Node

0.9.8

History Node

0.9.7

History Node

0.9.6

History Node

0.9.5

History Node

0.9.4

History Node

0.9.3

History Node

0.9.2

History Node

0.9.1

History Node

0.9.0

History Node

0.8.0

History Node

0.7.2

History Node

0.7.1

History Node

0.7.0

History Node

0.6.2

History Node

0.6.1

History Node

0.6.0

History Node

0.5.0

History Node

0.4.0

History Node

0.3.5

History Node

0.3.4

History Node

0.3.3

History Node

0.3.2

History Node

0.0.0

Download files

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

Filename, size & hash SHA256 hash help File type Python version Upload date
Kuyruk-0.24.1.tar.gz (34.0 kB) Copy SHA256 hash SHA256 Source None Jan 13, 2014

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging CloudAMQP CloudAMQP RabbitMQ AWS AWS Cloud computing Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page