|
@@ -60,6 +60,7 @@ class Scheduling:
|
|
@classmethod
|
|
@classmethod
|
|
def scheduling_task(cls, log_type, crawler, env, machine):
|
|
def scheduling_task(cls, log_type, crawler, env, machine):
|
|
task = cls.get_redis(log_type, crawler, env, machine)
|
|
task = cls.get_redis(log_type, crawler, env, machine)
|
|
|
|
+ Common.logger(log_type, crawler).info(f"task: {task}")
|
|
Common.logger(log_type, crawler).info(f"已获取调度任务:{task}")
|
|
Common.logger(log_type, crawler).info(f"已获取调度任务:{task}")
|
|
task_id = task['task_id']
|
|
task_id = task['task_id']
|
|
source = task['source']
|
|
source = task['source']
|