hw-cloudrobo-dataset 0.2.0
“CloudRobo Dataset Processing SDK and CLI”
imports osPython reads an environment variable
SHA-256d6afcf626dacf640fae0633de3abe82eba31a73311b54d509b66d57429ef68a5
MaleculeH₂(DbOs)
Evidence
1import json
2import logging
3import os
4import time
5from typing import Any, Callable, Dict, List, Optional
6
7from cloudrobo_core.sdk import BaseClient, Config
8
9logger = logging.getLogger(__name__)
10
11
12def is_debug_mode() -> bool:
13 """检测是否处于 debug 模式"""
14 env_val = os.environ.get("CLOUDROBO_DEBUG", "").lower()
15 if env_val in ("1", "true", "yes"):
16 return True
17 return logger.isEnabledFor(loggi …
⋯5 lines
85 if isinstance(value, str):
86 try:
87 parsed = json.loads(value)
88 if isinstance(parsed, list) and len(parsed) == 0:
89 empty.append(field_name)
90 …
⋯5 lines
95 if isinstance(spec, dict) and spec:
96 for key in SPEC_REQUIRED_KEYS:
97 if key not in spec:
98 empty.append(f"{spec_field}.{key}")
99
⋯5 lines
139:2… )
140 req["workspace_id"] = ws_id
141 return self._client.post(self._url("/v1/data-eng/proc-tasks"), json=req)
142
143 def list_tasks(self, workspace_id: Optional[str] = None, **params) -> Dict:
⋯6 lines
155:73… params={"ids": ",".join(task_ids)})
156
157 def update_task(self, task_id: str, req: Dict) -> Dict:
158 return self._client.patch(self._url(f"/v1/data-eng/proc-tasks/{task_id}"), json=req)
159
160 def …
No evidence locations were recorded for this file. Raw result