rendered paste bodydef RemoveCacheEntry():
syslog.syslog(syslog.LOG_NOTICE, 'removing cache entries')
dbh = psycopg.connect(DSN)
dbh.autocommit(0)
curs = dbh.cursor()
first_row = 1;
curs.execute("SELECT id, port_id, category, port FROM cache_clearing_ports ORDER BY id")
for row in curs.dictfetchall():
if (first_row):
min_id = row['id']
max_id = row['id']
first_row = 0
min_id = min(row['id'], min_id)
max_id = max(row['id'], max_id)
# other processing goes here
syslog.syslog(syslog.LOG_NOTICE, 'removing %s/%s' % (row['category'], row['port']))
syslog.syslog(syslog.LOG_NOTICE, 'removing entries between %s and %s' % (min_id, max_id))
# print "finished with RemoveCacheEntry"
return