|
|
@ -185,6 +185,7 @@ class Spider_task(threading.Thread):
|
|
|
|
self.free_remote_nodes.remove(f_node)
|
|
|
|
self.free_remote_nodes.remove(f_node)
|
|
|
|
break
|
|
|
|
break
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
|
|
|
|
logger.warning(f'[TASK] generate failed, no free remote nodes! spider task {task.request_map} is at state waiting...')
|
|
|
|
logger.info(f'[TASK] generating local task {task.request_map}')
|
|
|
|
logger.info(f'[TASK] generating local task {task.request_map}')
|
|
|
|
if global_var.spider.crawlers >= global_var.spider.max_count_of_crawlers:
|
|
|
|
if global_var.spider.crawlers >= global_var.spider.max_count_of_crawlers:
|
|
|
|
logger.warning(f'[TASK] generate failed, crawlers exceed! spider task {task.request_map} is at state waiting...')
|
|
|
|
logger.warning(f'[TASK] generate failed, crawlers exceed! spider task {task.request_map} is at state waiting...')
|
|
|
|