|
@@ -52,7 +52,7 @@ class AdPlatformArticlesDecodeTask(AdPlatformArticlesDecodeConst):
|
|
|
)
|
|
)
|
|
|
return
|
|
return
|
|
|
|
|
|
|
|
- task_id = response.get("data", {}).get("task_id")
|
|
|
|
|
|
|
+ task_id = response.get("data", {}).get("task_id") or response.get("data", {}).get("taskId")
|
|
|
if not task_id:
|
|
if not task_id:
|
|
|
# 解构任务创建失败
|
|
# 解构任务创建失败
|
|
|
await self.mapper.update_article_decode_status(
|
|
await self.mapper.update_article_decode_status(
|
|
@@ -135,7 +135,7 @@ class AdPlatformArticlesDecodeTask(AdPlatformArticlesDecodeConst):
|
|
|
return
|
|
return
|
|
|
|
|
|
|
|
response_data = response.get("data", {})
|
|
response_data = response.get("data", {})
|
|
|
- response_task_id = response_data.get("taskId")
|
|
|
|
|
|
|
+ response_task_id = response_data.get("taskId") or response_data.get("task_id")
|
|
|
if task_id != response_task_id:
|
|
if task_id != response_task_id:
|
|
|
# 解构任务获取失败
|
|
# 解构任务获取失败
|
|
|
await self.mapper.update_decode_task_status(
|
|
await self.mapper.update_decode_task_status(
|