feat(sdk): add workspace_id support across all SDK modules

Thread workspace_id parameter through all SDK resource clients and
high-level APIs: agent_runtime, conversation_service, credential,
knowledgebase, memory_collection, model, sandbox, super_agent,
tool, toolset, and shared utilities.

Change-Id: I9fc53cafa8237df8872de352115181c72414ef98
Co-developed-by: Claude <noreply@anthropic.com>
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
Signed-off-by: congxiao.wxx <congxiao.wxx@alibaba-inc.com>

Author: congxiao-wxx

agentrun/agent_runtime/api/data.py

@@ -6,7 +6,7 @@
 当前文件为自动生成的控制 API 客户端代码。请勿手动修改此文件。
 使用 `make codegen` 命令重新生成。
 
-source: agentrun/agent_runtime/api/__data_async_template.py
+source: .claude/worktrees/infallible-pasteur-94186e/agentrun/agent_runtime/api/__data_async_template.py
 """
 
 from typing import Iterable, Optional, TypedDict

agentrun/agent_runtime/client.py

@@ -6,7 +6,7 @@
 当前文件为自动生成的控制 API 客户端代码。请勿手动修改此文件。
 使用 `make codegen` 命令重新生成。
 
-source: agentrun/agent_runtime/__client_async_template.py
+source: .claude/worktrees/infallible-pasteur-94186e/agentrun/agent_runtime/__client_async_template.py
 
 Agent Runtime 客户端 / Agent Runtime Client
 
@@ -180,7 +180,9 @@ async def delete_async(
         except HTTPError as e:
             raise e.to_resource_error("AgentRuntime", id) from e
 
-    def delete(self, id: str, config: Optional[Config] = None) -> AgentRuntime:
+    def delete(
+        self, id: str, config: Optional[Config] = None
+    ) -> AgentRuntime:
         """同步删除 Agent Runtime / Delete Agent Runtime synchronously
 
         Args:
@@ -195,7 +197,9 @@ def delete(self, id: str, config: Optional[Config] = None) -> AgentRuntime:
             HTTPError: HTTP 请求错误 / HTTP request error
         """
         try:
-            result = self.__control_api.delete_agent_runtime(id, config=config)
+            result = self.__control_api.delete_agent_runtime(
+                id, config=config
+            )
             # Delete 响应只有 agentRuntimeId 有效，其他字段为空字符串/零值，
             # 走 from_inner_object 会在 status/artifactType 等 Enum 字段上触发
             # 伪校验错误。这里直接构造一个只带 id 的极简对象。
@@ -443,12 +447,14 @@ def create_endpoint(
             HTTPError: HTTP 请求错误 / HTTP request error
         """
         try:
-            result = self.__control_api.create_agent_runtime_endpoint(
-                agent_runtime_id,
-                CreateAgentRuntimeEndpointInput().from_map(
-                    endpoint.model_dump()
-                ),
-                config=config,
+            result = (
+                self.__control_api.create_agent_runtime_endpoint(
+                    agent_runtime_id,
+                    CreateAgentRuntimeEndpointInput().from_map(
+                        endpoint.model_dump()
+                    ),
+                    config=config,
+                )
             )
         except HTTPError as e:
             raise e.to_resource_error(
@@ -521,10 +527,12 @@ def delete_endpoint(
             HTTPError: HTTP 请求错误 / HTTP request error
         """
         try:
-            result = self.__control_api.delete_agent_runtime_endpoint(
-                agent_runtime_id,
-                endpoint_id,
-                config=config,
+            result = (
+                self.__control_api.delete_agent_runtime_endpoint(
+                    agent_runtime_id,
+                    endpoint_id,
+                    config=config,
+                )
             )
         except HTTPError as e:
             raise e.to_resource_error(
@@ -604,13 +612,15 @@ def update_endpoint(
             HTTPError: HTTP 请求错误 / HTTP request error
         """
         try:
-            result = self.__control_api.update_agent_runtime_endpoint(
-                agent_runtime_id,
-                endpoint_id,
-                UpdateAgentRuntimeEndpointInput().from_map(
-                    endpoint.model_dump()
-                ),
-                config=config,
+            result = (
+                self.__control_api.update_agent_runtime_endpoint(
+                    agent_runtime_id,
+                    endpoint_id,
+                    UpdateAgentRuntimeEndpointInput().from_map(
+                        endpoint.model_dump()
+                    ),
+                    config=config,
+                )
             )
         except HTTPError as e:
             raise e.to_resource_error(
@@ -759,10 +769,14 @@ def list_endpoints(
             if input is None:
                 input = AgentRuntimeEndpointListInput()
 
-            results = self.__control_api.list_agent_runtime_endpoints(
-                agent_runtime_id,
-                ListAgentRuntimeEndpointsRequest().from_map(input.model_dump()),
-                config=config,
+            results = (
+                self.__control_api.list_agent_runtime_endpoints(
+                    agent_runtime_id,
+                    ListAgentRuntimeEndpointsRequest().from_map(
+                        input.model_dump()
+                    ),
+                    config=config,
+                )
             )
             return [
                 AgentRuntimeEndpoint.from_inner_object(item)
@@ -833,10 +847,14 @@ def list_versions(
             if input is None:
                 input = AgentRuntimeVersionListInput()
 
-            results = self.__control_api.list_agent_runtime_versions(
-                agent_runtime_id,
-                ListAgentRuntimeVersionsRequest().from_map(input.model_dump()),
-                config=config,
+            results = (
+                self.__control_api.list_agent_runtime_versions(
+                    agent_runtime_id,
+                    ListAgentRuntimeVersionsRequest().from_map(
+                        input.model_dump()
+                    ),
+                    config=config,
+                )
             )
             return [
                 AgentRuntimeVersion.from_inner_object(item)

agentrun/agent_runtime/endpoint.py

@@ -6,7 +6,7 @@
 当前文件为自动生成的控制 API 客户端代码。请勿手动修改此文件。
 使用 `make codegen` 命令重新生成。
 
-source: agentrun/agent_runtime/__endpoint_async_template.py
+source: .claude/worktrees/infallible-pasteur-94186e/agentrun/agent_runtime/__endpoint_async_template.py
 
 Agent Runtime 端点资源 / Agent Runtime Endpoint Resource
 
@@ -413,7 +413,9 @@ async def list_by_id_async(
         return results
 
     @classmethod
-    def list_by_id(cls, agent_runtime_id: str, config: Optional[Config] = None):
+    def list_by_id(
+        cls, agent_runtime_id: str, config: Optional[Config] = None
+    ):
         """根据 Agent Runtime ID 同步列出所有端点 / List all endpoints by Agent Runtime ID synchronously
 
         此方法会自动分页获取所有端点并去重。
@@ -488,7 +490,9 @@ async def delete_async(
         self.update_self(result)
         return self
 
-    def delete(self, config: Optional[Config] = None) -> "AgentRuntimeEndpoint":
+    def delete(
+        self, config: Optional[Config] = None
+    ) -> "AgentRuntimeEndpoint":
         """同步删除当前端点 / Delete current endpoint synchronously
 
         Args:
@@ -719,7 +723,9 @@ def invoke_openai(self, **kwargs: Unpack[InvokeArgs]):
         if self.__data_api is None:
             if not self.__agent_runtime_name:
                 client = self.__get_client(cfg)
-                ar = client.get(id=self.agent_runtime_id or "", config=cfg)
+                ar = client.get(
+                    id=self.agent_runtime_id or "", config=cfg
+                )
                 self.__agent_runtime_name = ar.agent_runtime_name
 
             self.__data_api = AgentRuntimeDataAPI(

agentrun/agent_runtime/runtime.py

@@ -6,7 +6,7 @@
 当前文件为自动生成的控制 API 客户端代码。请勿手动修改此文件。
 使用 `make codegen` 命令重新生成。
 
-source: agentrun/agent_runtime/__runtime_async_template.py
+source: .claude/worktrees/infallible-pasteur-94186e/agentrun/agent_runtime/__runtime_async_template.py
 
 Agent Runtime 高层 API / Agent Runtime High-Level API
 
@@ -172,6 +172,7 @@ def delete_by_id(cls, id: str, config: Optional[Config] = None):
 
         # 等待所有端点删除完成 / Wait for all endpoints to be deleted
         while len(cli.list_endpoints(id, config=config)) > 0:
+            
 
             time.sleep(1)
 
@@ -226,7 +227,9 @@ def update_by_id(
             ResourceNotExistError: 资源不存在 / Resource does not exist
             HTTPError: HTTP 请求错误 / HTTP request error
         """
-        return cls.__get_client(config=config).update(id, input, config=config)
+        return cls.__get_client(config=config).update(
+            id, input, config=config
+        )
 
     @classmethod
     async def get_by_id_async(cls, id: str, config: Optional[Config] = None):
@@ -620,7 +623,9 @@ def delete(self, config: Optional[Config] = None):
                 "agent_runtime_id is required to delete an Agent Runtime"
             )
 
-        result = self.delete_by_id(self.agent_runtime_id, config=config)
+        result = self.delete_by_id(
+            self.agent_runtime_id, config=config
+        )
         self.update_self(result)
         return self
 
@@ -670,7 +675,9 @@ def get(self, config: Optional[Config] = None):
                 "agent_runtime_id is required to get an Agent Runtime"
             )
 
-        result = self.get_by_id(self.agent_runtime_id, config=config)
+        result = self.get_by_id(
+            self.agent_runtime_id, config=config
+        )
         self.update_self(result)
         return self
 
@@ -912,6 +919,6 @@ def invoke_openai(
                 config=cfg,
             )
 
-        return self._data_api[agent_runtime_endpoint_name].invoke_openai(
-            **kwargs
-        )
+        return self._data_api[
+            agent_runtime_endpoint_name
+        ].invoke_openai(**kwargs)

agentrun/conversation_service/ots_backend.py

@@ -6,7 +6,7 @@
 当前文件为自动生成的控制 API 客户端代码。请勿手动修改此文件。
 使用 `make codegen` 命令重新生成。
 
-source: agentrun/conversation_service/__ots_backend_async_template.py
+source: .claude/worktrees/infallible-pasteur-94186e/agentrun/conversation_service/__ots_backend_async_template.py
 
 OTS 存储后端。
 
@@ -1175,7 +1175,9 @@ def put_session(self, session: ConversationSession) -> None:
 
         row = Row(primary_key, attribute_columns)
         condition = Condition(RowExistenceExpectation.IGNORE)
-        self._client.put_row(self._conversation_table, row, condition)
+        self._client.put_row(
+            self._conversation_table, row, condition
+        )
 
     async def get_session_async(
         self,
@@ -1257,7 +1259,9 @@ def delete_session_row(
         ]
         row = Row(primary_key)
         condition = Condition(RowExistenceExpectation.IGNORE)
-        self._client.delete_row(self._conversation_table, row, condition)
+        self._client.delete_row(
+            self._conversation_table, row, condition
+        )
 
     async def update_session_async(
         self,
@@ -1333,7 +1337,9 @@ def update_session(
                 ComparatorType.EQUAL,
             ),
         )
-        self._client.update_row(self._conversation_table, row, condition)
+        self._client.update_row(
+            self._conversation_table, row, condition
+        )
 
     async def list_sessions_async(
         self,
@@ -2411,7 +2417,9 @@ def put_state(
         # 如果是更新（version > 0），需要清理旧的分片列
         delete_cols: list[str] = []
         if version > 0:
-            old_chunk_count = self._get_chunk_count(table_name, primary_key)
+            old_chunk_count = self._get_chunk_count(
+                table_name, primary_key
+            )
 
             if new_chunk_count == 0 and old_chunk_count > 0:
                 # 旧的有分片，新的不分片：删除所有 state_N 列
@@ -3093,7 +3101,9 @@ def put_checkpoint_blob(
         ]
         row = Row(primary_key, attribute_columns)
         condition = Condition(RowExistenceExpectation.IGNORE)
-        self._client.put_row(self._checkpoint_blobs_table, row, condition)
+        self._client.put_row(
+            self._checkpoint_blobs_table, row, condition
+        )
 
     async def get_checkpoint_blobs_async(
         self,