squeue

squeue: A simple SQLite Queue


Keywords
sqlite, queue, job, workflow
License
BSD-3-Clause
Install
pip install squeue==1.2

Documentation

squeue: A simple SQLite Queue

squeue is used to create simple queues that can be persisted, then retrieved for work. It's very easy to create a mini workflow engine with this.

Main Features

  • Very compact
  • Few Dependencies

Usage

One can create a new queuable function (or unit of work) by using the @queue_function decorator.

@queue_function
def hello(world):
    return "Hello, {}!".format(world)
hello.delay("World")

It will get invoked when a worker process fetches a function to execute. Do check the provided test.py with this distribution.