2013-05-16 23:03:00 +02:00
|
|
|
"""
|
2013-05-27 20:27:57 +02:00
|
|
|
This is what job_function needs as parameter for each job to successfully
|
2013-05-16 23:03:00 +02:00
|
|
|
execute.
|
|
|
|
|
"""
|
|
|
|
|
|
2013-06-21 01:46:08 +02:00
|
|
|
from lib.core.command import Command
|
2013-05-27 19:30:49 +02:00
|
|
|
|
2013-05-30 04:20:35 +02:00
|
|
|
|
2013-05-29 22:52:54 +02:00
|
|
|
def generateId():
|
2013-05-30 04:20:35 +02:00
|
|
|
i = 0
|
2013-05-29 22:52:54 +02:00
|
|
|
while True:
|
2013-05-30 04:20:35 +02:00
|
|
|
yield i
|
|
|
|
|
i += 1
|
|
|
|
|
|
2013-05-16 23:03:00 +02:00
|
|
|
|
2013-05-27 01:44:28 +02:00
|
|
|
class JobInfo:
|
2013-06-21 02:20:58 +02:00
|
|
|
def __init__(self, service):
|
|
|
|
|
self.service = service
|
2013-05-29 22:52:54 +02:00
|
|
|
self.name = generateId()
|
2013-06-21 02:20:58 +02:00
|
|
|
self.job = None
|
2013-05-27 01:44:28 +02:00
|
|
|
|
|
|
|
|
def __str__(self):
|
2013-05-30 01:02:24 +02:00
|
|
|
return "JobInfo " + str(self.name)
|
2013-05-27 01:44:28 +02:00
|
|
|
|
2013-06-21 02:20:58 +02:00
|
|
|
def set_logger(self, log):
|
2013-05-27 03:13:08 +02:00
|
|
|
self.log = log
|
2013-06-21 02:20:58 +02:00
|
|
|
|
|
|
|
|
def set_job(self, job):
|
|
|
|
|
self.job = job
|
|
|
|
|
|
|
|
|
|
def handle_call(self):
|
2013-05-29 22:52:54 +02:00
|
|
|
self.log.d("handle call")
|
2013-06-21 02:20:58 +02:00
|
|
|
self.log.d(self.service)
|
2013-05-29 23:39:16 +02:00
|
|
|
try:
|
2013-06-21 02:20:58 +02:00
|
|
|
self.service._execute()
|
|
|
|
|
except Exception, e:
|
|
|
|
|
self.log.d(e)
|