debug--, and bury jobs when the server gets it just in case it takes a while

This commit is contained in:
Trever Fischer
2012-10-23 13:55:07 -04:00
parent 1747e3794b
commit 9775dd46df
2 changed files with 1 additions and 2 deletions

View File

@@ -91,7 +91,6 @@ def send_web_event(event):
while len(latest) > 10:
latest.pop(0)
cache.set('minecraft-web-events', latest, 86400);
print 'cache:', latest
if settings.CAMINUS_USE_BEANSTALKD:
queue = beanstalkc.Connection(host=settings.CAMINUS_BEANSTALKD_HOST,
port = settings.CAMINUS_BEANSTALKD_PORT)
@@ -103,7 +102,6 @@ def send_web_event(event):
if pendingJob:
pending = loads(pendingJob.body)
if time.time()-pending['stamp'] > 30:
print "Deleting expired job", pendingJob.jid
pendingJob.delete()
queue.put(json)

View File

@@ -92,6 +92,7 @@ class ServerEventHandler(BaseHandler):
events = []
job = queue.reserve(timeout=30)
if job:
job.bury()
events.append({'id': job.jid, 'event': json.loads(job.body)})
return {'events': events}