修改main

main.py

@@ -19,7 +19,8 @@ async def run(task_id, mode, platform):
     """
     # 创建并等待一个子进程
     await asyncio.create_subprocess_shell(
-        "python3 scheduler/run_spider_online.py --task_id {} --mode {} --platform {}".format(task_id, mode, platform))
+        "python3 scheduler/run_spider_online.py --task_id {} --mode {} --platform {}".format(task_id, mode, platform)
+    )
 
 
 async def main():

scheduler/run_spider_online.py

@@ -7,7 +7,6 @@ sys.path.append(os.getcwd())
 
 from application.common.mysql import MysqlHelper
 from application.config import spider_map
-from application.spider.crawler_online import *
 
 
 class OnlineManager(object):