@@ -9,7 +9,7 @@ class Scheduler:
self.mrq = (queue or RedisQueue())
def _add_tasks(self, classify: str, tasks, level=1, group='', **kwargs):
- allow_output_log = kwargs.get('allow_output_log', True)
+ allow_output_log = kwargs.pop('allow_output_log', True)
if isinstance(tasks, list):
_tasks = tasks
else:
