Retask: simple Task Queue

retask is a python module to create and manage distributed task queue/job queue.

It uses Redis to create task queues. User can enqueue and dequeue tasks in the queues they manage. Each task can contain any JSON serializable python objects. We use JSON internally to store the tasks in the queues.

Workers can execute tasks and return the result asynchronously and if required synchronously (wait until worker returns the result to the job).

Dependencies

• python-redis
• mock
• A running Redis server

User Guide

• Introduction
  • First requirement
  • Why Redis
  • Retask License
• Setting up the Redis Server
• Installation
  • Distribute & Pip
  • Get the Code
  • Installing redis-py
• Quickstart
  • producer.py
  • consumer.py
• Tutorials
  • Async data transfer between producer and worker
  • Synchronous / blocking wait for the result

API Documentation

• API
  • Submodules
  • Exceptions

Indices and tables

• Index