refactor: add deprecation warnings to Threads class without changing logic

- Restore original threads.py from fedf9f8
- Add only deprecation warnings, no logic changes
- Keep all super() calls unchanged (get, update, delete)
- Add warnings to: create, retrieve, update, delete, create_and_run
- All tests pass (5/5)

Author: zhansheng.lzs

dashscope/threads/threads.py

@@ -2,7 +2,7 @@
 # Copyright (c) Alibaba, Inc. and its affiliates.
 
 import warnings
-from typing import Dict, List
+from typing import Dict, List, Optional
 
 from dashscope.assistants.assistant_types import DeleteResponse
 from dashscope.client.base_api import (
@@ -12,11 +12,10 @@
     UpdateMixin,
 )
 from dashscope.common.error import InputRequired
-from dashscope.threads.thread_types import Thread
+from dashscope.threads.thread_types import Run, Thread
 
 __all__ = ["Threads"]
 
-# Deprecation warning message
 _DEPRECATION_MSG = (
     "The Assistants API (dashscope.threads) is deprecated and will be "
     "removed in a future release. Please migrate to the Responses API. "
@@ -186,13 +185,12 @@ def update(  # type: ignore[override]
         api_key: str = None,
         **kwargs,
     ) -> Thread:
-        """Update the thread.
+        """Update thread information.
 
         Args:
-            thread_id (str): The target thread.
+            thread_id (str): The thread id.
             metadata (Dict, optional):
-                The key-value information associate with thread. Defaults to
-                None.
+                The thread key-value information. Defaults to None.
             workspace (str, optional):
                 The DashScope workspace id. Defaults to None.
             api_key (str, optional): Your DashScope api key. Defaults to None.
@@ -207,37 +205,36 @@ def update(  # type: ignore[override]
         )
         if not thread_id:
             raise InputRequired("thread_id is required!")
-        data = {"thread_id": thread_id}
-        if metadata:
-            data["metadata"] = metadata
-        response = super().call(
-            data=data,
+        response = super().update(
+            thread_id,
+            json={"metadata": metadata},
             api_key=api_key,
-            flattened_output=True,
             workspace=workspace,
+            flattened_output=True,
+            method="post",
             **kwargs,
         )
         return Thread(**response)
 
     @classmethod
     def delete(  # type: ignore[override]
         cls,
-        thread_id: str,
+        thread_id,
         *,
         workspace: str = None,
         api_key: str = None,
         **kwargs,
     ) -> DeleteResponse:
-        """Delete the thread.
+        """Delete thread.
 
         Args:
-            thread_id (str): The target thread.
+            thread_id (str): The thread id to delete.
             workspace (str, optional):
                 The DashScope workspace id. Defaults to None.
             api_key (str, optional): Your DashScope api key. Defaults to None.
 
         Returns:
-            DeleteResponse: The delete response.
+            AssistantsDeleteResponse: The deleted information.
         """
         warnings.warn(
             _DEPRECATION_MSG,
@@ -254,3 +251,49 @@ def delete(  # type: ignore[override]
             **kwargs,
         )
         return DeleteResponse(**response)
+
+    @classmethod
+    def create_and_run(
+        cls,
+        *,
+        assistant_id: str,
+        thread: Optional[Dict] = None,
+        model: Optional[str] = None,
+        instructions: Optional[str] = None,
+        additional_instructions: Optional[str] = None,
+        tools: Optional[List[Dict]] = None,
+        metadata: Optional[Dict] = None,
+        workspace: str = None,
+        api_key: str = None,
+        **kwargs,
+    ) -> Run:
+        warnings.warn(
+            _DEPRECATION_MSG,
+            category=DeprecationWarning,
+            stacklevel=2,
+        )
+        if not assistant_id:
+            raise InputRequired("assistant_id is required")
+        data = {"assistant_id": assistant_id}
+        if thread:
+            data["thread"] = thread
+        if model:
+            data["model"] = model
+        if instructions:
+            data["instructions"] = instructions
+        if additional_instructions:
+            data["additional_instructions"] = additional_instructions
+        if tools:
+            data["tools"] = tools
+        if metadata:
+            data["metadata"] = metadata
+
+        response = super().call(
+            data=data,
+            path="threads/runs",
+            api_key=api_key,
+            flattened_output=True,
+            workspace=workspace,
+            **kwargs,
+        )
+        return Run(**response)