0x2620/openmedialibrary
1
0
Fork 0
Code Issues 131 Pull requests Releases Wiki Activity

try to not stop task queue on failure

Browse source
This commit is contained in:
j 2015-11-16 16:52:14 +01:00
parent 909e38c302
commit d30ff2b4de
1 changed files with 15 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
oml/tasks.py
View file

@ -9,7 +9,7 @@ from websocket import trigger_event
import logging import logging
logger = logging.getLogger('oml.websocket') logger = logging.getLogger('oml.tasks')
class Tasks(Thread): class Tasks(Thread):
@ -26,17 +26,20 @@ class Tasks(Thread):
while self.connected: while self.connected:
m = self.q.get() m = self.q.get()
if m: if m:
action, data = m try:
if action == 'ping': action, data = m
trigger_event('pong', data) if action == 'ping':
elif action == 'import': trigger_event('pong', data)
item.scan.run_import(data) elif action == 'import':
elif action == 'scan': item.scan.run_import(data)
item.scan.run_scan() elif action == 'scan':
elif action == 'update': item.scan.run_scan()
trigger_event('error', {'error': 'not implemented'}) elif action == 'update':
else: trigger_event('error', {'error': 'not implemented'})
trigger_event('error', {'error': 'unknown action'}) else:
trigger_event('error', {'error': 'unknown action'})
except:
logger.debug('task failed', exc_info=1)
self.q.task_done() self.q.task_done()
def join(self): def join(self):