174 class SchedulerHandler(object): |
174 class SchedulerHandler(object): |
175 """Scheduler handler""" |
175 """Scheduler handler""" |
176 |
176 |
177 def get_jobs(self, settings): |
177 def get_jobs(self, settings): |
178 scheduler = self.process.scheduler |
178 scheduler = self.process.scheduler |
179 return [{'id': job.id, |
179 return [200, |
180 'name': job.name, |
180 [{'id': job.id, |
181 'trigger': '{0!s}'.format(job.trigger), |
181 'name': job.name, |
182 'next_run': job.next_run_time.timestamp()} for job in scheduler.get_jobs()] |
182 'trigger': '{0!s}'.format(job.trigger), |
|
183 'next_run': job.next_run_time.timestamp()} for job in scheduler.get_jobs()]] |
183 |
184 |
184 def reset_task(self, settings): |
185 def reset_task(self, settings): |
185 TaskResettingThread(self.process, settings).start() |
186 TaskResettingThread(self.process, settings).start() |
186 return 'OK' |
187 return [200, 'OK'] |
187 |
188 |
188 def remove_task(self, settings): |
189 def remove_task(self, settings): |
189 TaskRemoverThread(self.process, settings).start() |
190 TaskRemoverThread(self.process, settings).start() |
190 return 'OK' |
191 return [200, 'OK'] |
191 |
192 |
192 def run_task(self, settings): |
193 def run_task(self, settings): |
193 TaskRunnerThread(self.process, settings).start() |
194 TaskRunnerThread(self.process, settings).start() |
194 return 'OK' |
195 return [200, 'OK'] |
195 |
196 |
196 |
197 |
197 class SchedulerMessageHandler(ZMQMessageHandler): |
198 class SchedulerMessageHandler(ZMQMessageHandler): |
198 """ØMQ scheduler messages handler""" |
199 """ØMQ scheduler messages handler""" |
199 |
200 |