zombies.py

import os
import psycopg2

conn = psycopg2.connect(os.environ['PGCONNECTIONSTRING'])
cur = conn.cursor()

all_worker_ids = set(["t-yosemite-r7-0040", "t-yosemite-r7-0041", "t-yosemite-r7-0042", "t-yosemite-r7-0045"])

try:
    cur.execute("select worker_id, count(*) from tasks where provisioner = 'scl3-puppet' and resolved > now() - interval '5 hours' group by worker_id")
    found_ids = set([r[0] for r in cur])
    possible_zombies = all_worker_ids - found_ids
    print possible_zombies
finally:
    cur.close()
    conn.close()