linspector/linspector-old
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

added logs for task execution debugging

Browse source
This commit is contained in:
Rafael.Timmerberg 2013-12-10 18:00:34 +01:00
commit b93b2aee50
3 changed files with 15 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
bin/linspector
View file

@ -114,7 +114,9 @@ def main():
logger.error(msg) logger.error(msg)
exit() exit()
TaskExecutor.Instance() task = TaskExecutor.Instance()
logger.debug("blah")
#logger.debug("task executor instance :%s", str(task))
job_count = 0 job_count = 0
for layout in lin_conf.get_enabled_layouts(): for layout in lin_conf.get_enabled_layouts():

5
linspector/core/job.py
View file

@ -115,8 +115,11 @@ class LinspectorJob:
for task in member.get_tasks(): for task in member.get_tasks():
if self.status.lower() in task.get_task_type().lower(): if self.status.lower() in task.get_task_type().lower():
logger.debug("Executing Task of type: " + self.status) logger.debug("Executing Task of type: " + self.status)
TaskExecutor.Instance().schedule_task(job_information, task) try:
TaskExecutor.Instance().schedule_task(job_information, task)
except Exception, e:
logger.error("Error while executing: " + str(e))
def handle_call(self): def handle_call(self):
logger.debug("handle call") logger.debug("handle call")
logger.debug(self.service) logger.debug(self.service)

9
linspector/tasks/task.py
View file

@ -77,6 +77,7 @@ class Task(object):
@Singleton @Singleton
class TaskExecutor(object): class TaskExecutor(object):
def __init__(self): def __init__(self):
logger.debug("init taskExecutor")
self.event = Event() self.event = Event()
self.taskInfos = [] self.taskInfos = []
task_thread = Thread(target=self._run_worker_thread) task_thread = Thread(target=self._run_worker_thread)
@ -88,18 +89,22 @@ class TaskExecutor(object):
def _run_worker_thread(self): def _run_worker_thread(self):
while self.is_running() or not self.is_instant_end(): while self.is_running() or not self.is_instant_end():
if len(self.taskInfos) == 0: if len(self.taskInfos) == 0:
logger.debug("waiting for jobs to add")
self.event.clear() self.event.clear()
self.event.wait() self.event.wait()
logger.debug("Task Executor waked up")
try: try:
logger.debug("trying to get task information")
msg, task = self.taskInfos[0] msg, task = self.taskInfos[0]
del self.taskInfos[0] del self.taskInfos[0]
if task: if task:
logger.debug("Starting Task Execution...") logger.debug("Starting Task Execution of task: %s", str(task))
task.execute(msg) task.execute(msg)
except Exception, e: except Exception, e:
logger.error("Error " + str(e)) logger.error("Error " + str(e))
logger.debug("shutting down TaskExecutor!")
def is_instant_end(self): def is_instant_end(self):
return self._instantEnd return self._instantEnd
@ -117,5 +122,7 @@ class TaskExecutor(object):
self.event.set() self.event.set()
def schedule_task(self, msg, task): def schedule_task(self, msg, task):
logger.debug("appending task '%s' for msg: %s", str(task), str(msg))
self.taskInfos.append((msg, task)) self.taskInfos.append((msg, task))
logger.debug("%s task stored", str(len(self.taskInfos)))
self.event.set() self.event.set()