Liderahenk/Ahenk
1
0
Fork 0
mirror of https://github.com/Pardus-LiderAhenk/ahenk synced 2024-11-25 13:32:22 +03:00
Code Issues Projects Releases Packages Wiki Activity

variable naming fixed

Browse source
This commit is contained in:
Volkan Şahin 2016-10-19 12:15:29 +03:00
parent 7ea8f11a61
commit d4a8b30a4f
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
opt/ahenk/base/task/task_in_queue.py
View file

@ -10,15 +10,15 @@ from base.task.task_job import TaskJob
class TaskInQueue(threading.Thread): class TaskInQueue(threading.Thread):
"""docstring for TaskInQueue""" """docstring for TaskInQueue"""
def __init__(self, inQueue): def __init__(self, in_queue):
super(TaskInQueue, self).__init__() super(TaskInQueue, self).__init__()
self.inQueue = inQueue self.in_queue = in_queue
def run(self): def run(self):
# Add task to db. Adding task to db important because task can be lost when processing. # Add task to db. Adding task to db important because task can be lost when processing.
# Call plugin manager and process message inside task job # Call plugin manager and process message inside task job
try: try:
task = self.inQueue.get() task = self.in_queue.get()
print(task) print(task)
# Can be validate task before processing # Can be validate task before processing
job = TaskJob(task) job = TaskJob(task)