diff --git a/app/scheduler.py b/app/scheduler.py
index b5510514..06acb337 100644
--- a/app/scheduler.py
+++ b/app/scheduler.py
@@ -60,8 +60,7 @@ def process_pending_tasks():
 
     if tasks.count() > 0:
         pool = ThreadPool(tasks.count())
-        for task in tasks:
-           pool.apply_async(process, args=(task, ))
+        pool.map(process, tasks, chunksize=1)
         pool.close()
         pool.join()