[update]add function calling test

examples.json

@@ -0,0 +1,34 @@
+[
+    [
+        "Math Tutor",
+        "You are a personal math tutor. Write and run code to answer math questions.",
+        "Official math test case",
+        null,
+        null,
+        "gpt-4-1106-preview",
+        "123 * 524 等于多少？",
+        "Math Tutor 数学导师，一个最简单的 Agent，即没有函数调用，也没有文本检索。"
+    ],
+    [
+        "小说专家",
+        "根据小说内容回答问题。",
+        "三国演义文档问答测试",
+        "{\"type\": \"retrieval\"}",
+        [
+            "data/三国演义.txt"
+        ],
+        "gpt-4-1106-preview",
+        "刘备和张飞是什么关系。",
+        "基于文本检索的问答机器人，目前我也没有找到调整 chunk_size 的方法。"
+    ],
+    [
+        "Weather Bot",
+        "You are a weather bot. Use the provided functions to answer questions.",
+        "Function calling test case",
+        "{\"type\": \"function\", \"function\": {\"name\": \"get_current_weather\", \"description\": \"Get the current weather in a given location\", \"parameters\": {\"type\": \"object\", \"properties\": {\"location\": {\"type\": \"string\", \"description\": \"The city and state, e.g. San Francisco, CA\"}, \"unit\": {\"type\": \"string\", \"enum\": [\"celsius\", \"fahrenheit\"]}}, \"required\": [\"location\"]}}}",
+        null,
+        "gpt-4-1106-preview",
+        "What's the weather san francisco",
+        "Weather Bot 天气查询，一个基于函数调用的机器人。\n在左边栏的 function script 标签中可以查看有哪些函数可用。\n例如有一个函数叫作 “get_current_weather” 则有一个名为 “get_current_weather.py” 的 python 脚本，其中包含一个名为 “get_current_weather” 的函数。\n当函数被调用时，程序会自动导入该函数并调用。\n因此，你也可以上传自己的函数。"
+    ]
+]

examples/test/dynamic_import_package.py

@@ -0,0 +1,51 @@
+#!/usr/bin/python3
+# -*- coding: utf-8 -*-
+import argparse
+import importlib
+import time
+
+from openai import OpenAI
+from openai.pagination import SyncCursorPage
+from openai.types.beta.threads import ThreadMessage
+
+from project_settings import environment, project_path
+
+
+def get_args():
+    parser = argparse.ArgumentParser()
+    parser.add_argument(
+        "--package_name",
+        default="get_current_weather",
+        type=str
+    )
+    parser.add_argument(
+        "--function_name",
+        default="get_current_weather",
+        type=str
+    )
+    args = parser.parse_args()
+    return args
+
+
+def main():
+    args = get_args()
+
+    lib = importlib.import_module("functions.{}".format(args.package_name))
+    print(lib)
+
+    function_to_call = getattr(lib, args.function_name)
+    print(function_to_call)
+
+    result = function_to_call("beijing")
+    print(result)
+
+    del lib
+
+    lib = importlib.import_module("functions.not_exist")
+    print(lib)
+
+    return
+
+
+if __name__ == '__main__':
+    main()

examples/test/test_assistant/test_assistant_function_call.py

@@ -0,0 +1,218 @@
+#!/usr/bin/python3
+# -*- coding: utf-8 -*-
+"""
+https://platform.openai.com/docs/assistants/tools/function-calling
+"""
+import argparse
+import json
+import time
+
+from openai import OpenAI
+from openai.pagination import SyncCursorPage
+from openai.types.beta.threads import ThreadMessage
+from openai.types.beta.assistant import Assistant
+
+from project_settings import environment, project_path
+
+
+def get_args():
+    parser = argparse.ArgumentParser()
+    parser.add_argument(
+        "--openai_api_key",
+        default=environment.get("openai_api_key", default=None, dtype=str),
+        type=str
+    )
+    args = parser.parse_args()
+    return args
+
+
+def get_current_weather(location, unit="fahrenheit"):
+    if "tokyo" in location.lower():
+        return json.dumps({"location": location, "temperature": "10", "unit": "celsius"})
+    elif "san francisco" in location.lower():
+        return json.dumps({"location": location, "temperature": "72", "unit": "fahrenheit"})
+    else:
+        return json.dumps({"location": location, "temperature": "22", "unit": "celsius"})
+
+
+available_functions = {
+    "get_current_weather": get_current_weather,
+}
+
+
+def main():
+    """
+    assistant.id: asst_9iUOSeG3dUgzBxYqfygvtKLi
+    thread.id: thread_9C4dDj5i4jDCtkMCujyBleOc
+
+    """
+    args = get_args()
+
+    client = OpenAI(
+        api_key=args.openai_api_key
+    )
+
+    tools = [
+        {
+            "type": "function",
+            "function": {
+                "name": "get_current_weather",
+                "description": "Get the current weather in a given location",
+                "parameters": {
+                    "type": "object",
+                    "properties": {
+                        "location": {
+                            "type": "string",
+                            "description": "The city and state, e.g. San Francisco, CA",
+                        },
+                        "unit": {"type": "string", "enum": ["celsius", "fahrenheit"]},
+                    },
+                    "required": ["location"],
+                },
+            },
+        }
+    ]
+    tools_ = json.dumps(tools, ensure_ascii=False)
+    print(tools_.replace("\"", "\\\""))
+    exit(0)
+
+    assistant = client.beta.assistants.create(
+        instructions="You are a weather bot. Use the provided functions to answer questions.",
+        model="gpt-4-1106-preview",
+        tools=tools
+    )
+    print(f"assistant.id: {assistant.id}")
+
+    thread = client.beta.threads.create()
+    print(f"thread.id: {thread.id}")
+
+    message = client.beta.threads.messages.create(
+        thread_id=thread.id,
+        role="user",
+        content="what's the whether San Francisco"
+    )
+
+    run = client.beta.threads.runs.create(
+        thread_id=thread.id,
+        assistant_id=assistant.id,
+        instructions="Please address the user as Jane Doe. The user has a premium account."
+    )
+
+    delta_time = 0.3
+
+    no_update_count = 0
+    max_no_update_count = 10
+    while True:
+        if no_update_count > max_no_update_count:
+            break
+        time.sleep(delta_time)
+
+        run = client.beta.threads.runs.retrieve(
+            thread_id=thread.id,
+            run_id=run.id
+        )
+        print("run.required_action: {}".format(run.required_action))
+        if run.required_action is None:
+            no_update_count += 1
+            continue
+        else:
+
+            if run.required_action.type != "submit_tool_outputs":
+                raise AssertionError
+
+            tool_outputs = list()
+            for tool_call in run.required_action.submit_tool_outputs.tool_calls:
+                function_name = tool_call.function.name
+                function_to_call = available_functions[function_name]
+                function_args = json.loads(tool_call.function.arguments)
+                function_response = function_to_call(
+                    location=function_args.get("location"),
+                    unit=function_args.get("unit"),
+                )
+                tool_outputs.append({
+                    "tool_call_id": tool_call.id,
+                    "output": function_response,
+                })
+
+            run = client.beta.threads.runs.submit_tool_outputs(
+                thread_id=thread.id,
+                run_id=run.id,
+                tool_outputs=tool_outputs
+            )
+            no_update_count = 0
+
+    # wait complete
+    while True:
+        time.sleep(delta_time)
+        run = client.beta.threads.runs.retrieve(
+            thread_id=thread.id,
+            run_id=run.id
+        )
+        print(run.created_at)
+        print(run.started_at)
+        print(run.completed_at)
+        print(run.failed_at)
+        print(run.expires_at)
+        print(run.cancelled_at)
+
+        if run.completed_at is not None:
+            break
+        if run.failed_at is not None:
+            break
+        if run.expires_at is not None:
+            break
+        if run.cancelled_at is not None:
+            break
+
+    # messages
+    messages = client.beta.threads.messages.list(
+        thread_id=thread.id
+    )
+    messages = messages.model_dump(mode="json")
+    messages = json.dumps(messages, indent=4, ensure_ascii=False)
+    print(messages)
+
+    return
+
+
+def main2():
+    """
+    assistant.id: asst_OrPcAueQLrLYxtksFaPVVeJo
+    thread.id: thread_2oJCtoSCYgguOhdssafJM7ab
+    run: run_cA8DtX8EnoVGhmvu4VrvF63O
+    run.required_action: None
+    run id: 2090622954288
+    run: run_cA8DtX8EnoVGhmvu4VrvF63O
+    run.required_action: None
+    run id: 2090623149056
+
+    run.required_action: RequiredAction(submit_tool_outputs=RequiredActionSubmitToolOutputs(tool_calls=[RequiredActionFunctionToolCall(id='call_jalze5uKemfrnkPiJPRehVt0', function=Function(arguments='{"location":"San Francisco, CA"}', name='getCurrentWeather'), type='function')]), type='submit_tool_outputs')
+
+    """
+    args = get_args()
+
+    client = OpenAI(
+        api_key=args.openai_api_key
+    )
+
+    thread_id = "thread_2oJCtoSCYgguOhdssafJM7ab"
+    run_id = "run_cA8DtX8EnoVGhmvu4VrvF63O"
+
+    run = client.beta.threads.runs.retrieve(
+        thread_id=thread_id,
+        run_id=run_id
+    )
+    print("run: {}".format(run.id))
+    print("run.required_action: {}".format(run.required_action))
+    print("run id: {}".format(id(run)))
+
+    messages = client.beta.threads.messages.list(
+        thread_id=thread_id
+    )
+    print(messages)
+
+    return
+
+
+if __name__ == '__main__':
+    main()

examples/test/test_assistant/test_function_call.py

@@ -0,0 +1,118 @@
+#!/usr/bin/python3
+# -*- coding: utf-8 -*-
+"""
+https://platform.openai.com/docs/guides/function-calling
+"""
+import argparse
+import json
+import time
+
+import openai
+from openai import OpenAI
+from openai.pagination import SyncCursorPage
+from openai.types.beta.threads import ThreadMessage
+from openai.types.beta.assistant import Assistant
+
+from project_settings import environment, project_path
+
+
+def get_args():
+    parser = argparse.ArgumentParser()
+    parser.add_argument(
+        "--openai_api_key",
+        default=environment.get("openai_api_key", default=None, dtype=str),
+        type=str
+    )
+    args = parser.parse_args()
+    return args
+
+
+def get_current_weather(location, unit="fahrenheit"):
+    if "tokyo" in location.lower():
+        return json.dumps({"location": location, "temperature": "10", "unit": "celsius"})
+    elif "san francisco" in location.lower():
+        return json.dumps({"location": location, "temperature": "72", "unit": "fahrenheit"})
+    else:
+        return json.dumps({"location": location, "temperature": "22", "unit": "celsius"})
+
+
+available_functions = {
+    "get_current_weather": get_current_weather,
+}
+
+
+def main():
+    """
+    assistant.id: asst_9iUOSeG3dUgzBxYqfygvtKLi
+    thread.id: thread_9C4dDj5i4jDCtkMCujyBleOc
+
+    """
+    args = get_args()
+
+    client = OpenAI(
+        api_key=args.openai_api_key
+    )
+
+    messages = [{"role": "user", "content": "What's the weather like in San Francisco, Tokyo, and Paris?"}]
+
+    tools = [
+        {
+            "type": "function",
+            "function": {
+                "name": "get_current_weather",
+                "description": "Get the current weather in a given location",
+                "parameters": {
+                    "type": "object",
+                    "properties": {
+                        "location": {
+                            "type": "string",
+                            "description": "The city and state, e.g. San Francisco, CA",
+                        },
+                        "unit": {"type": "string", "enum": ["celsius", "fahrenheit"]},
+                    },
+                    "required": ["location"],
+                },
+            },
+        }
+    ]
+
+    response = openai.chat.completions.create(
+        model="gpt-3.5-turbo-1106",
+        messages=messages,
+        tools=tools,
+        tool_choice="auto",  # auto is default, but we'll be explicit
+    )
+    print(response.choices)
+    response_message = response.choices[0].message
+    tool_calls = response_message.tool_calls
+    print(tool_calls)
+
+    if tool_calls:
+        messages.append(response_message)
+        for tool_call in tool_calls:
+            function_name = tool_call.function.name
+            function_to_call = available_functions[function_name]
+            function_args = json.loads(tool_call.function.arguments)
+            function_response = function_to_call(
+                location=function_args.get("location"),
+                unit=function_args.get("unit"),
+            )
+            messages.append(
+                {
+                    "tool_call_id": tool_call.id,
+                    "role": "tool",
+                    "name": function_name,
+                    "content": function_response,
+                }
+            )
+        second_response = openai.chat.completions.create(
+            model="gpt-3.5-turbo-1106",
+            messages=messages,
+        )
+        print("second_response: {}".format(second_response))
+
+    return
+
+
+if __name__ == '__main__':
+    main()

functions/__init__.py

@@ -0,0 +1,6 @@
+#!/usr/bin/python3
+# -*- coding: utf-8 -*-
+
+
+if __name__ == '__main__':
+    pass

functions/get_current_weather.py

@@ -0,0 +1,22 @@
+#!/usr/bin/python3
+# -*- coding: utf-8 -*-
+import json
+
+
+def get_current_weather(location, unit="fahrenheit"):
+    if "tokyo" in location.lower():
+        return json.dumps({"location": location, "temperature": "10", "unit": "celsius"})
+    elif "san francisco" in location.lower():
+        return json.dumps({"location": location, "temperature": "72", "unit": "fahrenheit"})
+    else:
+        return json.dumps({"location": location, "temperature": "22", "unit": "celsius"})
+
+
+def main():
+    result = get_current_weather("beijing")
+    print(result)
+    return
+
+
+if __name__ == '__main__':
+    main()

main.py

@@ -5,13 +5,17 @@ https://huggingface.co/spaces/fffiloni/langchain-chat-with-pdf-openai
 """
 import argparse
 import httpx
+import importlib
 import json
 import logging
+import os
+import platform
+import shutil
 import time
 from typing import List, Tuple
 
 logging.basicConfig(
-    level=logging.DEBUG,
+    level=logging.INFO if platform.system() == "Windows" else logging.DEBUG,
     format="%(asctime)s %(levelname)s %(message)s",
     datefmt="%Y-%m-%d %H:%M:%S",
 )
@@ -31,6 +35,11 @@ logger = logging.getLogger(__name__)
 
 def get_args():
     parser = argparse.ArgumentParser()
+    parser.add_argument(
+        "--examples_json_file",
+        default="examples.json",
+        type=str
+    )
     parser.add_argument(
         "--openai_api_key",
         default=settings.environment.get("openai_api_key", default=None, dtype=str),
@@ -40,10 +49,16 @@ def get_args():
     return args
 
 
-def greet(question: str, history: List[Tuple[str, str]]):
-    answer = "Hello " + question + "!"
-    result = history + [(question, answer)]
-    return result
+def dynamic_import_function(package_name: str, function_name: str):
+    try:
+        lib = importlib.import_module("functions.{}".format(package_name))
+        print(lib)
+    except ModuleNotFoundError as e:
+        raise e
+
+    function = getattr(lib, function_name)
+
+    return function
 
 
 def click_create_assistant(openai_api_key: str,
@@ -98,11 +113,7 @@ def click_create_assistant(openai_api_key: str,
     )
     assistant_id = assistant.id
 
-    # thread
-    thread = client.beta.threads.create()
-    thread_id = thread.id
-
-    return assistant_id, thread_id
+    return assistant_id, None
 
 
 def click_list_assistant(openai_api_key: str) -> str:
@@ -138,6 +149,17 @@ def click_delete_assistant(openai_api_key: str,
     return result
 
 
+def click_delete_all_assistant(openai_api_key: str):
+    client = OpenAI(
+        api_key=openai_api_key,
+    )
+    assistant_list = client.beta.assistants.list()
+
+    for a in assistant_list.data:
+        client.beta.assistants.delete(a.id)
+    return None
+
+
 def click_list_file(openai_api_key: str):
     client = OpenAI(
         api_key=openai_api_key,
@@ -197,140 +219,38 @@ def click_upload_files(openai_api_key: str,
     return result
 
 
-def get_message_list(client: OpenAI, thread_id: str):
-    """
-    SyncCursorPage[ThreadMessage](
-        data=[
-            ThreadMessage(
-                id='msg_kb0f2fyDC6OwMyXxKbUpcuBS',
-                assistant_id='asst_DzVVZkE0dIGe0gsOdsdn3A0w',
-                content=[
-                    MessageContentText(
-                        text=Text(
-                            annotations=[
-                                TextAnnotationFileCitation(
-                                    end_index=44,
-                                    file_citation=TextAnnotationFileCitationFileCitation(
-                                        file_id='file-IwzwXQkixMu7fvgGoC1alIWu',
-                                        quote='念刘备、关羽、张飞，虽然异姓，既结为兄弟，则同心协力，救困扶危；上报国家，下安黎庶。不求同年同月同日生，只愿同年同月同日死。皇天后土，实鉴此心，背义忘恩，天人共戮！”誓毕，拜玄德为兄，关羽次之，张飞为弟'
-                                    ),
-                                    start_index=34,
-                                    text='【7†source】',
-                                    type='file_citation'
-                                )
-                            ],
-                            value='刘备和张飞虽然是异姓，但他们结为了兄弟，其中刘备被拜为兄，而张飞为弟【7†source】。'
-                        ),
-                        type='text'
-                    )
-                ],
-                created_at=1699493845,
-                file_ids=[],
-                metadata={},
-                object='thread.message',
-                role='assistant',
-                run_id='run_zJYZX0KFEvEh2VG5x5zSLq9s',
-                thread_id='thread_3JWRdjvZDJTBgZ0tlrrKXnrt'
-            ),
-
-            ThreadMessage(
-                id='msg_tc5Tit7q19S5TSgvmBauME3H',
-                assistant_id=None,
-                content=[
-                    MessageContentText(
-                        text=Text(
-                            annotations=[],
-                            value='刘备和张飞是什么关系。'
-                        ),
-                        type='text'
-                    )
-                ],
-                created_at=1699493838,
-                file_ids=[],
-                metadata={},
-                object='thread.message',
-                role='user',
-                run_id=None,
-                thread_id='thread_3JWRdjvZDJTBgZ0tlrrKXnrt'
-            )
-
-        ],
-        object='list',
-        first_id='msg_kb0f2fyDC6OwMyXxKbUpcuBS',
-        last_id='msg_tc5Tit7q19S5TSgvmBauME3H',
-        has_more=False
-    )
-    """
-    messages = client.beta.threads.messages.list(
-        thread_id=thread_id
-    )
-    # print(messages)
-
-    result = list()
-    for message in messages.data:
-
-        content = list()
-        for msg in message.content:
-            annotations = list()
-            for annotation in msg.text.annotations:
-                a = {
-                    "start_index": annotation.start_index,
-                    "end_index": annotation.end_index,
-                    "text": annotation.text,
-                    "type": annotation.type,
-                }
-
-                if annotation.type == "file_citation":
-                    a["file_citation"] = {
-                        "file_id": annotation.file_citation.file_id,
-                        "quote": annotation.file_citation.quote,
-                    }
-
-                annotations.append(a)
-
-            content.append({
-                "text": {
-                    "annotations": annotations,
-                    "value": msg.text.value,
-                },
-                "type": msg.type,
-
-            })
-
-        result.append({
-            "id": message.id,
-            "assistant_id": message.assistant_id,
-            "content": content,
-            "created_at": message.created_at,
-            "file_ids": message.file_ids,
-            "metadata": message.metadata,
-            "object": message.object,
-            "role": message.role,
-            "run_id": message.run_id,
-            "thread_id": message.thread_id,
-
-        })
-
-    result = list(sorted(result, key=lambda x: x["created_at"]))
+def click_list_function_python_script():
+    function_script_dir = project_path / "functions"
+    result = ""
+    for script in function_script_dir.glob("*.py"):
+        if script.name == "__init__.py":
+            continue
+        result += script.name
+        result += "\n"
     return result
 
 
-def convert_message_list_to_response(message_list: List[dict]) -> str:
-    response = ""
-    for message in message_list:
-        role = message["role"]
-        content = message["content"]
+def click_upload_function_python_script(files: List[str]):
+    tgt = project_path / "functions"
+    if files is None:
+        return None
+    for file in files:
+        shutil.copy(file, tgt.as_posix())
+    return None
 
-        for c in content:
-            if c["type"] != "text":
-                continue
-            text: dict = c["text"]
-            msg = "{}: \n{}\n".format(role, text["value"])
-            response += msg
-            response += "-" * 80
-            response += "\n"
 
-    return response
+def click_delete_function_python_script(filename: str):
+    function_script_dir = project_path / "functions"
+    filename = function_script_dir / filename.strip()
+    filename = filename.as_posix()
+    try:
+        os.remove(filename)
+        result = "success"
+    except FileNotFoundError as e:
+        result = str(e)
+    except Exception as e:
+        result = str(e)
+    return result
 
 
 def convert_message_list_to_conversation(message_list: List[dict]) -> List[Tuple[str, str]]:
@@ -370,30 +290,6 @@ def convert_message_list_to_conversation(message_list: List[dict]) -> List[Tuple
     return conversation
 
 
-def streaming_refresh(openai_api_key: str,
-                      thread_id: str,
-                      queue: Queue,
-                      ):
-    delta_time = 0.3
-    last_response = None
-    no_updates_count = 0
-    max_no_updates_count = 5
-    while True:
-        time.sleep(delta_time)
-
-        this_response = refresh(openai_api_key, thread_id)
-
-        if this_response == last_response:
-            no_updates_count += 1
-        if no_updates_count >= max_no_updates_count:
-            break
-        last_response = this_response
-
-        queue.put(this_response, block=True, timeout=2)
-
-    return last_response
-
-
 def refresh(openai_api_key: str,
             thread_id: str,
             ):
@@ -401,9 +297,14 @@ def refresh(openai_api_key: str,
         api_key=openai_api_key,
     )
 
-    message_list = get_message_list(client, thread_id=thread_id)
-    # print(message_list)
-    logger.info("message_list: {}".format(message_list))
+    message_list = client.beta.threads.messages.list(
+        thread_id=thread_id
+    )
+    message_list = message_list.model_dump(mode="json")
+    message_list = message_list["data"]
+    message_list = list(sorted(message_list, key=lambda x: x["created_at"]))
+
+    logger.debug("message_list: {}".format(message_list))
     conversation = convert_message_list_to_conversation(message_list)
     return conversation
 
@@ -424,7 +325,7 @@ def add_and_run(openai_api_key: str,
         api_key=openai_api_key,
     )
     if assistant_id is None or len(assistant_id.strip()) == 0:
-        assistant_id = click_create_assistant(
+        assistant_id, _ = click_create_assistant(
             openai_api_key,
             name, instructions, description, tools, files, file_ids, model
         )
@@ -433,6 +334,8 @@ def add_and_run(openai_api_key: str,
         thread = client.beta.threads.create()
         thread_id = thread.id
 
+    logger.info(f"assistant_id: {assistant_id}, thread_id: {thread_id}")
+
     message = client.beta.threads.messages.create(
         thread_id=thread_id,
         role="user",
@@ -442,42 +345,57 @@ def add_and_run(openai_api_key: str,
         thread_id=thread_id,
         assistant_id=assistant_id,
     )
-    run = client.beta.threads.runs.retrieve(
-        thread_id=thread_id,
-        run_id=run.id
-    )
-
-    response_queue = Queue(maxsize=10)
-    refresh_kwargs = dict(
-        openai_api_key=openai_api_key,
-        thread_id=thread_id,
-        queue=response_queue,
-    )
-    thread = Thread(target=streaming_refresh, kwargs=refresh_kwargs)
-    thread.start()
 
     delta_time = 0.1
-    last_response = None
+    last_conversation = None
     no_updates_count = 0
-    max_no_updates_count = 10
+    max_no_updates_count = 5
     while True:
         time.sleep(delta_time)
+        run = client.beta.threads.runs.retrieve(
+            thread_id=thread_id,
+            run_id=run.id,
+        )
 
-        try:
-            this_response = response_queue.get(block=True, timeout=2)
-        except _queue.Empty:
-            break
+        # required action
+        if run.required_action is not None:
+            if run.required_action.type == "submit_tool_outputs":
+                tool_outputs = list()
+                for tool_call in run.required_action.submit_tool_outputs.tool_calls:
+                    function_name = tool_call.function.name
+                    function_to_call = dynamic_import_function(function_name, function_name)
+                    function_args = json.loads(tool_call.function.arguments)
+                    function_response = function_to_call(
+                        location=function_args.get("location"),
+                        unit=function_args.get("unit"),
+                    )
+                    tool_outputs.append({
+                        "tool_call_id": tool_call.id,
+                        "output": function_response,
+                    })
+
+                run = client.beta.threads.runs.submit_tool_outputs(
+                    thread_id=thread_id,
+                    run_id=run.id,
+                    tool_outputs=tool_outputs
+                )
+
+        # get message
+        conversation = refresh(openai_api_key, thread_id)
+        if conversation == last_conversation:
+            if any([run.completed_at is not None,
+                    run.cancelled_at is not None,
+                    run.failed_at is not None,
+                    run.expires_at is not None]):
+                no_updates_count += 1
 
-        if this_response == last_response:
-            no_updates_count += 1
         if no_updates_count >= max_no_updates_count:
             break
-        last_response = this_response
+        last_conversation = conversation
 
         result = [
             assistant_id, thread_id,
-            last_response,
-            []
+            conversation,
         ]
         yield result
 
@@ -489,6 +407,16 @@ def main():
     OpenAI Assistant
     """
 
+    # example json
+    with open(args.examples_json_file, "r", encoding="utf-8") as f:
+        examples = json.load(f)
+    for example in examples:
+        files: List[str] = example[4]
+        if files is None:
+            continue
+        files = [(project_path / file).as_posix() for file in files]
+        example[4] = files
+
     # ui
     with gr.Blocks() as blocks:
         gr.Markdown(value=gr_description)
@@ -520,23 +448,35 @@ def main():
                         # create assistant
                         create_assistant_button = gr.Button("create assistant")
 
-                    with gr.TabItem("list assistant"):
+                    with gr.TabItem("assistants"):
                         list_assistant_button = gr.Button("list assistant")
                         assistant_list = gr.TextArea(label="assistant_list")
 
-                        delete_assistant_id = gr.Textbox(label="delete_assistant_id")
+                        delete_assistant_id = gr.Textbox(max_lines=1, label="delete_assistant_id")
                         delete_assistant_button = gr.Button("delete assistant")
 
-                    with gr.TabItem("list file"):
+                        delete_all_assistant_button = gr.Button("delete all assistant")
+
+                    with gr.TabItem("files"):
                         list_file_button = gr.Button("list file")
                         file_list = gr.TextArea(label="file_list")
 
-                        delete_file_id = gr.Textbox(label="delete_file_id")
-                        delete_file_button = gr.Button("delete file")
-
                         upload_files = gr.Files(label="upload_files")
                         upload_files_button = gr.Button("upload file")
 
+                        delete_file_id = gr.Textbox(max_lines=1, label="delete_file_id")
+                        delete_file_button = gr.Button("delete file")
+
+                    with gr.TabItem("function script"):
+                        list_function_python_script_button = gr.Button("list python script")
+                        list_function_python_script_list = gr.TextArea(label="python_script_list")
+
+                        upload_function_python_script_files = gr.Files(label="upload_python_script_files")
+                        upload_function_python_script_button = gr.Button("upload python script")
+
+                        delete_function_python_script_file = gr.Textbox(max_lines=1, label="delete_python_script_file")
+                        delete_function_python_script_button = gr.Button("delete python script")
+
             # chat
             with gr.Column(scale=5):
                 chat_bot = gr.Chatbot(label="conversation", height=600)
@@ -553,34 +493,15 @@ def main():
                 assistant_id = gr.Textbox(value=None, label="assistant_id")
                 thread_id = gr.Textbox(value=None, label="thread_id")
 
+                tips = gr.TextArea(value=None, label="tips")
+
         # examples
         with gr.Row():
             gr.Examples(
-                examples=[
-                    [
-                        "Math Tutor",
-                        "You are a personal math tutor. Write and run code to answer math questions.",
-                        "Official math test cases",
-                        None,
-                        None,
-                        "gpt-4-1106-preview",
-                        "123 * 524 等于多少？"
-                    ],
-                    [
-                        "小说专家",
-                        "根据小说内容回答问题。",
-                        "三国演义文档问答测试",
-                        "{\"type\": \"retrieval\"}",
-                        [
-                            (project_path / "data/三国演义.txt").as_posix()
-                        ],
-                        "gpt-4-1106-preview",
-                        "刘备和张飞是什么关系。"
-                    ],
-                ],
+                examples=examples,
                 inputs=[
                     name, instructions, description, tools, retrieval_files, model,
-                    query,
+                    query, tips
                 ],
                 examples_per_page=5
             )
@@ -620,6 +541,17 @@ def main():
             ]
         )
 
+        # delete all assistant
+        delete_all_assistant_button.click(
+            click_delete_all_assistant,
+            inputs=[
+                openai_api_key
+            ],
+            outputs=[
+                file_list
+            ]
+        )
+
         # list file
         list_file_button.click(
             click_list_file,
@@ -655,6 +587,37 @@ def main():
             ]
         )
 
+        # list python script
+        list_function_python_script_button.click(
+            click_list_function_python_script,
+            inputs=[],
+            outputs=[
+                list_function_python_script_list
+            ]
+        )
+
+        # upload function python script
+        upload_function_python_script_button.click(
+            click_upload_function_python_script,
+            inputs=[
+                upload_function_python_script_files
+            ],
+            outputs=[
+                upload_function_python_script_files
+            ]
+        )
+
+        # delete function python script
+        delete_function_python_script_button.click(
+            click_delete_function_python_script,
+            inputs=[
+                delete_function_python_script_file
+            ],
+            outputs=[
+                delete_function_python_script_file
+            ]
+        )
+
         # add and run
         add_and_run_button.click(
             add_and_run,