@@ -26,6 +26,7 @@ max_concurrency = env.int("concurrency", 20)
async def handle(producer, data: dict):
result = await task_distribute(data)
+
print("send : ", result)
if result is not None:
许家凯