Tried removing one background line

pull/40/head
Piero Toffanin 2016-10-29 20:07:47 -04:00
rodzic c43a002caf
commit 100fec6808
2 zmienionych plików z 4 dodań i 4 usunięć

Wyświetl plik

@ -91,7 +91,7 @@ class TaskViewSet(viewsets.ViewSet):
serializer.save() serializer.save()
# Call the scheduler (speed things up) # Call the scheduler (speed things up)
scheduler.process_pending_tasks(background=True) #scheduler.process_pending_tasks(background=True)
return Response(serializer.data) return Response(serializer.data)

Wyświetl plik

@ -11,7 +11,7 @@ import random
logger = logging.getLogger('app.logger') logger = logging.getLogger('app.logger')
scheduler = BackgroundScheduler() scheduler = BackgroundScheduler()
def job(func): def background(func):
""" """
Adds background={True|False} param to any function Adds background={True|False} param to any function
so that we can call update_nodes_info(background=True) from the outside so that we can call update_nodes_info(background=True) from the outside
@ -27,7 +27,7 @@ def job(func):
return wrapper return wrapper
@job @background
def update_nodes_info(): def update_nodes_info():
processing_nodes = ProcessingNode.objects.all() processing_nodes = ProcessingNode.objects.all()
for processing_node in processing_nodes: for processing_node in processing_nodes:
@ -36,7 +36,7 @@ def update_nodes_info():
tasks_mutex = Lock() tasks_mutex = Lock()
@job @background
def process_pending_tasks(): def process_pending_tasks():
tasks = [] tasks = []
try: try: