decentral1se/pandora
1
0
Fork 0
forked from 0x2620/pandora
Code Issues Pull requests Projects Releases Wiki Activity

formating

Browse source
This commit is contained in:
j 2016-06-16 14:47:45 +02:00
parent 70f34bfde9
commit f25218466b
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
pandora/archive/queue.py
View file

@ -52,7 +52,7 @@ def fill_queue():
elif f.data: elif f.data:
f.extract_stream() f.extract_stream()
else: else:
print('not sure what to do with' ,f) print('not sure what to do with', f)
check.append(f) check.append(f)
in_queue.append(f.oshash) in_queue.append(f.oshash)
for f in File.objects.filter(encoding=True).exclude(oshash__in=in_queue): for f in File.objects.filter(encoding=True).exclude(oshash__in=in_queue):
@ -61,7 +61,7 @@ def fill_queue():
elif f.data: elif f.data:
f.extract_stream() f.extract_stream()
else: else:
print('not sure what to do with' ,f) print('not sure what to do with', f)
check.append(f) check.append(f)
return check return check
@ -72,13 +72,13 @@ def get_celery_worker_status():
insp = celery.task.control.inspect() insp = celery.task.control.inspect()
d = insp.stats() d = insp.stats()
if not d: if not d:
d = { ERROR_KEY: 'No running Celery workers were found.' } d = {ERROR_KEY: 'No running Celery workers were found.'}
except IOError as e: except IOError as e:
from errno import errorcode from errno import errorcode
msg = "Error connecting to the backend: " + str(e) msg = "Error connecting to the backend: " + str(e)
if len(e.args) > 0 and errorcode.get(e.args[0]) == 'ECONNREFUSED': if len(e.args) > 0 and errorcode.get(e.args[0]) == 'ECONNREFUSED':
msg += ' Check that the RabbitMQ server is running.' msg += ' Check that the RabbitMQ server is running.'
d = { ERROR_KEY: msg } d = {ERROR_KEY: msg}
except ImportError as e: except ImportError as e:
d = { ERROR_KEY: str(e)} d = {ERROR_KEY: str(e)}
return d return d