Simple Queue Jobs TF Fork
Project description
Origin
This is a fork of the original [sqjobs](https://github.com/igalarzab/sqjobs/)
Installation
Simply use pip to install the last version of sqjobs
pip install --upgrade sqjobs
Getting started
First you have to create jobs. A job is simply a class that inherits from Job.
from sqjobs import Job class Adder(Job): default_queue_name = 'queue_name' def run(self, num1, num2): return num1 + num2
Then, you can launch the job creating a new broker.
from sqjobs import create_sqs_broker broker = create_sqs_broker(access_key='ak', secret_key='sk') broker.add_job(AdderJob, 1, 2, queue_name='other_queue_name')
Documentation
Check out sqjobs’s documentation for further information.
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Filename, size | File type | Python version | Upload date | Hashes |
---|---|---|---|---|
Filename, size sqjobstf-0.8.5.tar.gz (17.5 kB) | File type Source | Python version None | Upload date | Hashes View |