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