Merge pull request #551 from seymourtang/fix-lambda

fix: update lambda functions to include unused parameter
TEN-framework · Jan 3, 2025 · 95751b3 · 95751b3
2 parents 6c873a3 + 2ab7e7b
commit 95751b3
Show file tree

Hide file tree

Showing 15 changed files with 22 additions and 20 deletions.
diff --git a/agents/ten_packages/extension/cartesia_tts/tests/test_basic.py b/agents/ten_packages/extension/cartesia_tts/tests/test_basic.py
@@ -22,7 +22,7 @@ def on_start(self, ten_env: TenEnvTester) -> None:
         print("send hello_world")
         ten_env.send_cmd(
             new_cmd,
-            lambda ten_env, result: self.check_hello(ten_env, result),
+            lambda ten_env, result, _: self.check_hello(ten_env, result),
         )
 
         print("tester on_start_done")

diff --git a/agents/ten_packages/extension/cosy_tts_python/tests/test_basic.py b/agents/ten_packages/extension/cosy_tts_python/tests/test_basic.py
@@ -22,7 +22,7 @@ def on_start(self, ten_env: TenEnvTester) -> None:
         print("send hello_world")
         ten_env.send_cmd(
             new_cmd,
-            lambda ten_env, result: self.check_hello(ten_env, result),
+            lambda ten_env, result, _: self.check_hello(ten_env, result),
         )
 
         print("tester on_start_done")

diff --git a/agents/ten_packages/extension/dify_python/tests/test_basic.py b/agents/ten_packages/extension/dify_python/tests/test_basic.py
@@ -22,7 +22,7 @@ def on_start(self, ten_env: TenEnvTester) -> None:
         print("send hello_world")
         ten_env.send_cmd(
             new_cmd,
-            lambda ten_env, result: self.check_hello(ten_env, result),
+            lambda ten_env, result, _: self.check_hello(ten_env, result),
         )
 
         print("tester on_start_done")

diff --git a/agents/ten_packages/extension/elevenlabs_tts_python/tests/test_basic.py b/agents/ten_packages/extension/elevenlabs_tts_python/tests/test_basic.py
@@ -22,7 +22,7 @@ def on_start(self, ten_env: TenEnvTester) -> None:
         print("send hello_world")
         ten_env.send_cmd(
             new_cmd,
-            lambda ten_env, result: self.check_hello(ten_env, result),
+            lambda ten_env, result,_: self.check_hello(ten_env, result),
         )
 
         print("tester on_start_done")

diff --git a/agents/ten_packages/extension/file_chunker/file_chunker_extension.py b/agents/ten_packages/extension/file_chunker/file_chunker_extension.py
@@ -84,7 +84,7 @@ def create_collection(self, ten: TenEnv, collection_name: str, wait: bool):
         wait_event = threading.Event()
         ten.send_cmd(
             cmd_out,
-            lambda ten, result: wait_event.set(),
+            lambda ten, result, _: wait_event.set(),
         )
         if wait:
             wait_event.wait()
@@ -97,7 +97,7 @@ def embedding(self, ten: TenEnv, path: str, texts: List[str]):
         cmd_out = Cmd.create("embed_batch")
         cmd_out.set_property_from_json("inputs", json.dumps(texts))
         ten.send_cmd(
-            cmd_out, lambda ten, result: self.vector_store(ten, path, texts, result)
+            cmd_out, lambda ten, result, _: self.vector_store(ten, path, texts, result)
         )
 
     def vector_store(self, ten: TenEnv, path: str, texts: List[str], result: CmdResult):
@@ -114,7 +114,7 @@ def vector_store(self, ten: TenEnv, path: str, texts: List[str], result: CmdResu
             content.append({"text": text, "embedding": embedding})
         cmd_out.set_property_string("content", json.dumps(content))
         # ten.log_info(json.dumps(content))
-        ten.send_cmd(cmd_out, lambda ten, result: self.file_chunked(ten, path))
+        ten.send_cmd(cmd_out, lambda ten, result, _: self.file_chunked(ten, path))
 
     def file_chunked(self, ten: TenEnv, path: str):
         if path in self.counters and path in self.expected:
@@ -137,7 +137,7 @@ def file_chunked(self, ten: TenEnv, path: str):
                 cmd_out.set_property_string("collection", self.new_collection_name)
                 ten.send_cmd(
                     cmd_out,
-                    lambda ten, result: ten.log_info("send_cmd done"),
+                    lambda ten, result, _: ten.log_info("send_cmd done"),
                 )
                 self.file_chunked_event.set()
         else:

diff --git a/agents/ten_packages/extension/glue_python_async/tests/test_basic.py b/agents/ten_packages/extension/glue_python_async/tests/test_basic.py
@@ -22,7 +22,7 @@ def on_start(self, ten_env: TenEnvTester) -> None:
         print("send hello_world")
         ten_env.send_cmd(
             new_cmd,
-            lambda ten_env, result: self.check_hello(ten_env, result),
+            lambda ten_env, result, _: self.check_hello(ten_env, result),
         )
 
         print("tester on_start_done")

diff --git a/agents/ten_packages/extension/http_server_python/http_server_extension.py b/agents/ten_packages/extension/http_server_python/http_server_extension.py
@@ -25,7 +25,7 @@ def do_POST(self):
                 self.ten.log_info("incoming request %s", input_file)
                 self.ten.send_cmd(
                     Cmd.create_from_json(input_file),
-                    lambda ten, result: ten.log_info(
+                    lambda ten, result, _: ten.log_info(
                         "finish send_cmd from http server %s %s", input_file, result
                     ),
                 )

diff --git a/agents/ten_packages/extension/interrupt_detector_python/extension.py b/agents/ten_packages/extension/interrupt_detector_python/extension.py
@@ -52,7 +52,7 @@ def on_cmd(self, ten: TenEnv, cmd: Cmd) -> None:
         new_cmd.set_property_from_json(None, cmd_json)
         ten.send_cmd(
             new_cmd,
-            lambda ten, result: ten.log_info("send_cmd done"),
+            lambda ten, result, _: ten.log_info("send_cmd done"),
         )
 
         cmd_result = CmdResult.create(StatusCode.OK)

diff --git a/agents/ten_packages/extension/llama_index_chat_engine/llama_embedding.py b/agents/ten_packages/extension/llama_index_chat_engine/llama_embedding.py
@@ -39,7 +39,7 @@ def _get_query_embedding(self, query: str) -> List[float]:
         wait_event = threading.Event()
         resp: List[float]
 
-        def callback(_, result):
+        def callback(_, result, __):
             nonlocal resp
             nonlocal wait_event
 

diff --git a/agents/ten_packages/extension/llama_index_chat_engine/llama_llm.py b/agents/ten_packages/extension/llama_index_chat_engine/llama_llm.py
@@ -59,7 +59,7 @@ def chat(self, messages: Sequence[ChatMessage], **kwargs: Any) -> ChatResponse:
         resp: ChatResponse
         wait_event = threading.Event()
 
-        def callback(_, result):
+        def callback(_, result, __):
             self.ten.log_debug("LlamaLLM chat callback done")
             nonlocal resp
             nonlocal wait_event
@@ -71,7 +71,9 @@ def callback(_, result):
         cmd = Cmd.create("call_chat")
         cmd.set_property_string("messages", messages_str)
         cmd.set_property_bool("stream", False)
-        self.ten.log_info(f"LlamaLLM chat send_cmd {cmd.get_name()}, messages {messages_str}")
+        self.ten.log_info(
+            f"LlamaLLM chat send_cmd {cmd.get_name()}, messages {messages_str}"
+        )
 
         self.ten.send_cmd(cmd, callback)
         wait_event.wait()
@@ -103,7 +105,7 @@ def gen() -> ChatResponseGen:
                     delta=delta_text,
                 )
 
-        def callback(_, result):
+        def callback(_, result, __):
             nonlocal cur_tokens
             nonlocal resp_queue
 

diff --git a/agents/ten_packages/extension/llama_index_chat_engine/llama_retriever.py b/agents/ten_packages/extension/llama_index_chat_engine/llama_retriever.py
@@ -63,7 +63,7 @@ def _retrieve(self, query_bundle: QueryBundle) -> List[NodeWithScore]:
         wait_event = threading.Event()
         resp: List[NodeWithScore] = []
 
-        def cmd_callback(_, result):
+        def cmd_callback(_, result, __):
             nonlocal resp
             nonlocal wait_event
             resp = format_node_result(self.ten, result)

diff --git a/agents/ten_packages/extension/minimax_tts_python/tests/test_basic.py b/agents/ten_packages/extension/minimax_tts_python/tests/test_basic.py
@@ -22,7 +22,7 @@ def on_start(self, ten_env: TenEnvTester) -> None:
         print("send hello_world")
         ten_env.send_cmd(
             new_cmd,
-            lambda ten_env, result: self.check_hello(ten_env, result),
+            lambda ten_env, result, _: self.check_hello(ten_env, result),
         )
 
         print("tester on_start_done")

diff --git a/agents/ten_packages/extension/qwen_llm_python/qwen_llm_extension.py b/agents/ten_packages/extension/qwen_llm_python/qwen_llm_extension.py
@@ -269,7 +269,7 @@ def on_cmd(self, ten: TenEnv, cmd: Cmd) -> None:
             cmd_out = Cmd.create("flush")
             ten.send_cmd(
                 cmd_out,
-                lambda ten, result: ten.log_info("send_cmd flush done"),
+                lambda ten, result, _: ten.log_info("send_cmd flush done"),
             )
         elif cmd_name == "call_chat":
             self.queue.put((cmd, ts))

diff --git a/agents/ten_packages/extension/vision_analyze_tool_python/tests/test_basic.py b/agents/ten_packages/extension/vision_analyze_tool_python/tests/test_basic.py
@@ -22,7 +22,7 @@ def on_start(self, ten_env: TenEnvTester) -> None:
         print("send hello_world")
         ten_env.send_cmd(
             new_cmd,
-            lambda ten_env, result: self.check_hello(ten_env, result),
+            lambda ten_env, result, _: self.check_hello(ten_env, result),
         )
 
         print("tester on_start_done")

diff --git a/agents/ten_packages/extension/vision_tool_python/tests/test_basic.py b/agents/ten_packages/extension/vision_tool_python/tests/test_basic.py
@@ -22,7 +22,7 @@ def on_start(self, ten_env: TenEnvTester) -> None:
         print("send hello_world")
         ten_env.send_cmd(
             new_cmd,
-            lambda ten_env, result: self.check_hello(ten_env, result),
+            lambda ten_env, result, _: self.check_hello(ten_env, result),
         )
 
         print("tester on_start_done")