Skip to main content

Simple async worker

Project description

mod-ngarn

CircleCI PyPI version

Usage

Usage: mod-ngarn [OPTIONS] COMMAND [ARGS]...

Options:
  --help  Show this message and exit.

Commands:
  create-table     Create mod-ngarn queue table
  delete-job       Delete executed task
  run              Run mod-ngarn job
  wait-for-notify  Wait and listening for NOTIFY

Installation

pip install mod-ngarn

Run modngarn

Usage: mod-ngarn run [OPTIONS]

  Run mod-ngarn job

Options:
  --queue-table TEXT  Queue table name (Default: os.getenv("DBTABLE",
                      "public.modngarn_job"))
  --limit INTEGER     Limit jobs (Default: 300)
  --max-delay FLOAT   Max delay for failed jobs (seconds) (Default: None)
  --help              Show this message and exit.

Create modngarn job queue table

Usage: mod-ngarn create-table [OPTIONS]

Options:
  --queue-table TEXT  Queue table name (Default: os.getenv("DBTABLE",
                      "public.modngarn_job"))
  --help              Show this message and exit.

Wait for notify

Usage: mod-ngarn wait-for-notify [OPTIONS]

  Wait and listening for NOTIFY

Options:
  --queue-table TEXT  Queue table name (Default: os.getenv("DBTABLE",
                      "public.modngarn_job"))
  --help              Show this message and exit.

Delete executed job

Usage: mod-ngarn delete-job [OPTIONS]

  Delete executed task

Options:
  --queue-table TEXT  Queue table name (Default: os.getenv("DBTABLE",
                      "public.modngarn_job"))
  --help              Show this message and exit.

Example run script

#!/bin/bash
set -u

while true
do
    mod-ngarn run $*
    timeout 5 mod-ngarn wait-for-notify
done

Dev

Required

Setup

flit install

Runtests

./runtests.sh

Publish to PyPi

flit publish

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

mod_ngarn-3.5.tar.gz (14.5 kB view hashes)

Uploaded Source

Built Distribution

mod_ngarn-3.5-py2.py3-none-any.whl (24.5 kB view hashes)

Uploaded Python 2 Python 3

Supported by

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