diff --git a/cps/services/worker.py b/cps/services/worker.py index a22b9a71..05307b52 100644 --- a/cps/services/worker.py +++ b/cps/services/worker.py @@ -23,7 +23,7 @@ STAT_STARTED = 2 STAT_FINISH_SUCCESS = 3 # Only retain this many tasks in dequeued list -TASK_CLEANUP_TRIGGER = 5 +TASK_CLEANUP_TRIGGER = 20 QueuedTask = namedtuple('QueuedTask', 'num, user, added, task')