@@ -101,6 +101,14 @@ async def auto_create_crawler_task(plan_id, plan_name, plan_tag, url_list, platf
return res
+async def add_to_crawler_task():
+ pass
+
+async def get_crawler_task_detail():
async def auto_bind_crawler_task_to_generate_task(crawler_task_list, generate_task_id):
url = "http://aigc-api.cybertogether.net/aigc/produce/plan/save"
plan_info = await get_generate_task_detail(generate_task_id)
@@ -91,12 +91,19 @@ class TaskManagerService(TaskConst):
"""
list_params = (*params, page_size, offset)
rows = await self.pool.async_fetch(query=sql_list, params=list_params)
-
+ items = [
+ {
+ **r,
+ "status_text": self.STATUS_TEXT.get(r["task_status"], str(r["task_status"])),
+ "data_json": self.data
+ }
+ for r in rows
+ ]
return {
"total": total,
"page": page,
"page_size": page_size,
- "items": rows,
+ "items": items
}
async def get_task(self, task_id: int):