stackforge/libra
Code Issues Proposed changes

Merge "API: Add exception logging for gearman threads"

Browse Source
This commit is contained in:
Jenkins
2013-06-18 20:42:30 +00:00
committed by Gerrit Code Review
parent b2653dfe20 931f28195e
commit a795eddf29
1 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
libra/api/library/gearman_client.py
View File

@@ -39,13 +39,16 @@ def submit_job(job_type, host, data, lbid):
def client_job(logger, job_type, host, data, lbid): def client_job(logger, job_type, host, data, lbid):
client = GearmanClientThread(logger, host, lbid) try:
if job_type == 'UPDATE': client = GearmanClientThread(logger, host, lbid)
client.send_update(data) if job_type == 'UPDATE':
if job_type == 'DELETE': client.send_update(data)
client.send_delete(data) if job_type == 'DELETE':
if job_type == 'ARCHIVE': client.send_delete(data)
client.send_archive(data) if job_type == 'ARCHIVE':
client.send_archive(data)
except:
logger.exception("Gearman thread unhandled exception")
class GearmanClientThread(object): class GearmanClientThread(object):