diff --git a/domain-api/app/services/sync_push_service.py b/domain-api/app/services/sync_push_service.py index 55ac0bf..002258f 100644 --- a/domain-api/app/services/sync_push_service.py +++ b/domain-api/app/services/sync_push_service.py @@ -896,10 +896,11 @@ def pull_detect_task_batch_now(limit: int | None = None) -> tuple[bool, str, dic except Exception as exc: return False, f"拉取待检测任务失败: {exc}", {"action": "pull_tasks"} - if int(data.get("code", 1) or 1) != 0: + payload = data.get("data") or {} + response_code = data.get("code", 0) + if response_code not in (0, "0", None) and not payload: return False, str(data.get("message") or "拉取待检测任务失败"), {"action": "pull_tasks", "response": data} - payload = data.get("data") or {} source_record_id = int(payload.get("source_record_id") or 0) projection_hash = str(payload.get("projection_hash") or "").strip() projection = payload.get("projection") or {}