Renaming, another example, remove agentops

Author: cxbxmxcx

.env.default

@@ -1,7 +1,5 @@
 OPENAI_API_KEY="your openai api key here"
 
-AGENTOPS_API_KEY = "your agentops api key here"
-
 X_EMAIL = "twitter email here"
 X_USERNAME = "twitter username here"
 X_PASSWORD = "twitter password here"

agentic_btree_on_thread.py

@@ -0,0 +1,122 @@
+import textwrap
+import time
+
+import py_trees
+
+from playground.behavior_trees import (
+    create_assistant_action_on_thread,
+    create_assistant_condition,
+)
+from playground.assistants_api import api
+
+# Create the root node (sequence)
+root = py_trees.composites.Sequence("RootSequence", memory=True)
+
+# selector = py_trees.composites.Selector("Hacker Team Selector", memory=True)
+# root.add_child(selector)
+
+
+thread = api.create_thread()
+challenge = textwrap.dedent("""
+    Given a string of digits, return the longest substring with alternating odd/even or even/odd digits. 
+    If two or more substrings have the same length, return the substring that occurs first.
+    Examples
+
+    longest_substring("225424272163254474441338664823") ➞ "272163254"
+    # substrings = 254, 272163254, 474, 41, 38, 23
+
+    longest_substring("594127169973391692147228678476") ➞ "16921472"
+    # substrings = 94127, 169, 16921472, 678, 476
+
+    longest_substring("721449827599186159274227324466") ➞ "7214"
+    # substrings = 7214, 498, 27, 18, 61, 9274, 27, 32
+    # 7214 and 9274 have same length, but 7214 occurs first.
+
+    Notes
+
+    The minimum alternating substring size is 2, and there will always be at least one alternating substring.
+""")
+judge_test_cases = textwrap.dedent("""
+    Test.assert_equals(longest_substring("844929328912985315632725682153"), "56327256")
+    Test.assert_equals(longest_substring("769697538272129475593767931733"), "27212947")
+    Test.assert_equals(longest_substring("937948289456111258444958189244"), "894561")
+    Test.assert_equals(longest_substring("736237766362158694825822899262"), "636")
+    Test.assert_equals(longest_substring("369715978955362655737322836233"), "369")
+    Test.assert_equals(longest_substring("345724969853525333273796592356"), "496985")
+    Test.assert_equals(longest_substring("548915548581127334254139969136"), "8581")
+    Test.assert_equals(longest_substring("417922164857852157775176959188"), "78521")
+    Test.assert_equals(longest_substring("251346385699223913113161144327"), "638569")
+    Test.assert_equals(longest_substring("483563951878576456268539849244"), "18785")
+    Test.assert_equals(longest_substring("853667717122615664748443484823"), "474")
+    Test.assert_equals(longest_substring("398785511683322662883368457392"), "98785")
+    Test.assert_equals(longest_substring("368293545763611759335443678239"), "76361")
+    Test.assert_equals(longest_substring("775195358448494712934755311372"), "4947")
+    Test.assert_equals(longest_substring("646113733929969155976523363762"), "76523")
+    Test.assert_equals(longest_substring("575337321726324966478369152265"), "478369")
+    Test.assert_equals(longest_substring("754388489999793138912431545258"), "545258")
+    Test.assert_equals(longest_substring("198644286258141856918653955964"), "2581418569")
+    Test.assert_equals(longest_substring("643349187319779695864213682274"), "349")
+    Test.assert_equals(longest_substring("919331281193713636178478295857"), "36361")
+    Test.assert_equals(longest_substring("2846286484444288886666448822244466688822247"), "47")    
+""")
+
+hacker = create_assistant_action_on_thread(
+    thread=thread,
+    action_name="Hacker",
+    assistant_name="Python Coding Assistant",
+    assistant_instructions=textwrap.dedent(f"""
+    Challenge goal: 
+    {challenge}
+    Solve the challenge and output the final solution to a file called solution.py        
+    """),
+)
+root.add_child(hacker)
+
+judge = create_assistant_action_on_thread(
+    thread=thread,
+    action_name="Judge solution",
+    assistant_name="Coding Challenge Judge",
+    assistant_instructions=textwrap.dedent(
+        f"""
+    Challenge goal: 
+    {challenge}
+    Load the solution from the file solution.py.
+    Then confirm is a solution to the challenge and test it with the following test cases:
+    {judge_test_cases}  
+    Run the code for the solution and confirm it passes all the test cases.
+    If the solution passes all tests save the solution to a file called judged_solution.py
+    """,
+    ),
+)
+root.add_child(judge)
+
+# verifier operates on a different thread, essentially in closed room
+verifier = create_assistant_condition(
+    condition_name="Verify solution",
+    assistant_name="Python Coding Assistant",
+    assistant_instructions=textwrap.dedent(
+        f"""
+    Challenge goal: 
+    {challenge}
+    Load the file called judged_solution.py and verify that the solution is correct by running the code and confirm it passes all the test cases:
+    {judge_test_cases}
+    If the solution is correct, return only the single word SUCCESS, otherwise return the single word FAILURE.
+    """,
+    ),
+)
+root.add_child(verifier)
+
+# Create the behavior tree
+tree = py_trees.trees.BehaviourTree(root)
+
+# Tick the tree to run it
+# for i in range(1000):
+#     print(f"Tick {i + 1}")
+#     tree.tick()
+#     time.sleep(30)  # Simulate time between ticks
+
+while True:
+    tree.tick()
+    time.sleep(20)  # Simulate time between ticks
+    if root.status == py_trees.common.Status.SUCCESS:
+        break

btree_v1.py renamed to agentic_btree_v1.py

@@ -0,0 +1,3 @@
+Running on local URL:  http://127.0.0.1:7860
+
+To create a public link, set `share=True` in `launch()`.

btree_v2.py renamed to agentic_btree_v2.py

@@ -5,9 +5,7 @@
 from dotenv import load_dotenv
 
 from playground.assistants_utils import EventHandler
-import agentops
 
-from playground.utils import id_to_uuid
 
 load_dotenv()
 
@@ -174,16 +172,6 @@ def stream_worker(assistant_id, thread_id, event_handler):
             # yield history
             message["files"].append(eh.images.pop())
 
-        agentops.record(
-            agentops.LLMEvent(
-                thread_id=id_to_uuid(thread_id),
-                agent_id=id_to_uuid(assistant_id),
-                prompt=prompt,
-                completion=message["text"] + eh.internal_context,
-                model=assistant.model,
-            )
-        )
-
         return message
 
 

btree_v3.py renamed to agentic_btree_v3.py

@@ -4,7 +4,6 @@
 import py_trees
 
 from playground.assistants_api import api
-import agentops
 
 
 # Define the FunctionWrapper class
@@ -45,12 +44,9 @@ def long_running_process(self):
         # Simulate a long-running process
         try:
             print("%s: Thread started, running process..." % self.name)
-            agentops.init()
-            agentops.start_session()
             result = self.function_wrapper()
             print(result)
             if "FAILURE" in result["text"]:
-                agentops.end_session("Fail")
                 print("%s: Thread completed with failure." % self.name)
                 return
 
@@ -59,11 +55,9 @@ def long_running_process(self):
             else:
                 self.thread_success = True
 
-            agentops.end_session("Success")
             print("%s: Thread completed successfully." % self.name)
         except Exception as e:
             print("%s: Exception in thread: %s" % (self.name, str(e)))
-            agentops.end_session("Fail")
         finally:
             self.thread_running = False
 
@@ -105,3 +99,25 @@ def create_assistant_condition(condition_name, assistant_name, assistant_instruc
     return ActionWrapper(
         name=condition_name, function_wrapper=function_wrapper, is_condition=True
     )
+
+
+def create_assistant_action_on_thread(
+    thread, action_name, assistant_name, assistant_instructions
+):
+    assistant = api.get_assistant_by_name(assistant_name)
+    function_wrapper = FunctionWrapper(
+        api.call_assistant_with_thread, thread, assistant.id, assistant_instructions
+    )
+    return ActionWrapper(name=action_name, function_wrapper=function_wrapper)
+
+
+def create_assistant_condition_on_thread(
+    thread, condition_name, assistant_name, assistant_instructions
+):
+    assistant = api.get_assistant_by_name(assistant_name)
+    function_wrapper = FunctionWrapper(
+        api.call_assistant_with_thread, thread, assistant.id, assistant_instructions
+    )
+    return ActionWrapper(
+        name=condition_name, function_wrapper=function_wrapper, is_condition=True
+    )

logs/logs.txt

@@ -1,6 +1,5 @@
 gradio
 openai
-agentops
 wikipedia
 twitter-api-client
 python-dotenv