[WORKER]: Fix stupid mistakes
Change-Id: I51b846755309f1dac36f33253c672059ceea2d75
This commit is contained in:
@@ -25,6 +25,7 @@ class CustomJSONGearmanWorker(JSONGearmanWorker):
|
|||||||
""" Custom class we will use to pass arguments to the Gearman task. """
|
""" Custom class we will use to pass arguments to the Gearman task. """
|
||||||
logger = None
|
logger = None
|
||||||
driver = None
|
driver = None
|
||||||
|
args = None
|
||||||
|
|
||||||
|
|
||||||
def handler(worker, job):
|
def handler(worker, job):
|
||||||
@@ -37,6 +38,7 @@ def handler(worker, job):
|
|||||||
"""
|
"""
|
||||||
logger = worker.logger
|
logger = worker.logger
|
||||||
driver = worker.driver
|
driver = worker.driver
|
||||||
|
args = worker.args
|
||||||
|
|
||||||
# Hide information that should not be logged
|
# Hide information that should not be logged
|
||||||
copy = job.data.copy()
|
copy = job.data.copy()
|
||||||
@@ -45,7 +47,7 @@ def handler(worker, job):
|
|||||||
|
|
||||||
logger.debug("Received JSON message: %s" % json.dumps(copy))
|
logger.debug("Received JSON message: %s" % json.dumps(copy))
|
||||||
|
|
||||||
controller = LBaaSController(logger, driver, job.data)
|
controller = LBaaSController(logger, driver, job.data, args.server)
|
||||||
response = controller.run()
|
response = controller.run()
|
||||||
|
|
||||||
# Hide information that should not be logged
|
# Hide information that should not be logged
|
||||||
@@ -81,6 +83,7 @@ def config_thread(logger, driver, args):
|
|||||||
worker.register_task(hostname, handler)
|
worker.register_task(hostname, handler)
|
||||||
worker.logger = logger
|
worker.logger = logger
|
||||||
worker.driver = driver
|
worker.driver = driver
|
||||||
|
worker.args = args
|
||||||
|
|
||||||
retry = True
|
retry = True
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user