beatwatch 0.1.0

Tiny client for the BeatWatch dead-man's-switch monitor for cron and Celery jobs.

beatwatch

Tiny client for BeatWatch — the dead-man's-switch monitor for scheduled jobs.

Install

pip install beatwatch
# optional: pip install beatwatch[celery]

Usage

from beatwatch import ping, set_base_url

set_base_url("https://your-beatwatch.example.com")

def nightly_report():
    do_the_work()
    ping("<TOKEN>")  # non-blocking, never raises

Set BEATWATCH_BASE_URL env var instead of calling set_base_url, if you prefer.

Celery

from beatwatch.celery import monitored_task

@monitored_task("<TOKEN>")
def cleanup_old_records():
    OldRecord.objects.filter(stale=True).delete()

The ping is only emitted when the wrapped task returns successfully — failures don't ping, so missed pings really mean "the job didn't finish."