결과는 빚이야

import sqlite3

OUTCOME_REVIEW = 2 * 3600   # backstop after a managed accept
PARK = 30 * 86400           # a parked row waits for Dad or the worker

db = sqlite3.connect(':memory:')
db.execute("""CREATE TABLE obligations (
  item TEXT PRIMARY KEY,
  status TEXT NOT NULL DEFAULT 'pending',  -- pending | resolved
  due REAL NOT NULL,                       -- next eligible review
  parked INTEGER NOT NULL DEFAULT 0,
  reviewed REAL,                           -- last time a review looked
  disposition TEXT)""")

def accept(item, now):
    # In the real engine this shares a transaction with the take.
    db.execute('INSERT INTO obligations(item, due) VALUES (?, ?)', (item, now + OUTCOME_REVIEW))

def evidence(item, now):
    # Fresh worker evidence (a note): review now. Parked rows ignore it.
    db.execute("UPDATE obligations SET due = MIN(due, ?) "
               "WHERE item = ? AND status = 'pending' AND parked = 0", (now, item))

def sweep(now, limit=50):
    # What a review wakes for: pending and due. Nothing else.
    return [r[0] for r in db.execute(
        "SELECT item FROM obligations WHERE status = 'pending' AND due <= ? "
        "ORDER BY due LIMIT ?", (now, limit))]

def defer(item, now, after):
    # Resolves this review, keeps the obligation, arms the next one.
    db.execute("UPDATE obligations SET reviewed = ?, due = ?, parked = 0 WHERE item = ?",
               (now, now + after, item))

def park(item, now):
    db.execute("UPDATE obligations SET reviewed = ?, due = ?, parked = 1 WHERE item = ?",
               (now, now + PARK, item))

def report(item, outcome):
    # Only a disposition discharges the obligation.
    db.execute("UPDATE obligations SET status = 'resolved', disposition = ? "
               "WHERE item = ? AND status = 'pending'", (outcome, item))

H, D = 3600, 86400
accept('todo 1', 0)
accept('todo 2', 0)
print(sweep(10 * 60))        # []          accepted, nothing due yet
evidence('todo 1', 10 * 60)
print(sweep(10 * 60))        # ['todo 1']  a note arrived
defer('todo 1', 10 * 60, 30 * 60)
park('todo 2', 10 * 60)
print(sweep(1 * H))          # ['todo 1']  its deferral came due
report('todo 1', 'done')
evidence('todo 2', 2 * H)    # ignored: parked rows wait
print(sweep(3 * D))          # []
print(sweep(31 * D))         # ['todo 2']  the park ran out; still owed

# An outcome is reviewed when evidence arrives (a worker final, a blocked
# report, a lost session); these timers are only the backstop behind that.
OUTCOME_REVIEW_SECONDS = 2 * 3600
LEGACY_REVIEW_SECONDS = 3 * 3600
PARK_SECONDS = 30 * 86400
# A blocked report is never parked for good: the chief sweeps it again within
# this window, so a blocker that cleared (a push that later went through, a
# build Dad installed) or a proposal Dad already answered is picked up without
# Dad asking (Dad, 2026-10-08, todo #348).
BLOCKED_SWEEP_SECONDS = 6 * 3600