新框架 bug 暂停

app/main.py

@@ -86,8 +86,9 @@ async def main():
     """
     spider_list = TopicGroup().produce()
     while spider_list:
-        tasks = [consume_single_message(spider) for spider in spider_list]
-        await asyncio.gather(*tasks)
+        print(spider_list)
+        # tasks = [consume_single_message(spider) for spider in spider_list]
+        # await asyncio.gather(*tasks)
         await asyncio.sleep(60)