Fix init_sender not defined

autogen_utils.py

@@ -54,7 +54,9 @@ def get_retrieve_config(docs_path, model_name, collection_name):
 def termination_msg(x):
     """Check if a message is a termination message."""
     _msg = str(x.get("content", "")).upper().strip().strip("\n").strip(".")
-    return isinstance(x, dict) and (_msg.endswith("TERMINATE") or _msg.startswith("TERMINATE"))
+    return isinstance(x, dict) and (
+        _msg.endswith("TERMINATE") or _msg.startswith("TERMINATE")
+    )
 
 
 def _is_termination_msg(message):
@@ -107,7 +109,12 @@ def new_generate_oai_reply(
 
 
 def initialize_agents(
-    llm_config, agent_name, system_msg, agent_type, retrieve_config=None, code_execution_config=False
+    llm_config,
+    agent_name,
+    system_msg,
+    agent_type,
+    retrieve_config=None,
+    code_execution_config=False,
 ):
     agent_name = agent_name.strip()
     system_msg = system_msg.strip()
@@ -175,9 +182,13 @@ async def get_human_input(name, prompt: str, instance=None) -> str:
     """Get human input."""
     if instance is None:
         return input(prompt)
-    get_input_widget = pn.widgets.TextAreaInput(placeholder=prompt, name="", sizing_mode="stretch_width")
+    get_input_widget = pn.widgets.TextAreaInput(
+        placeholder=prompt, name="", sizing_mode="stretch_width"
+    )
     get_input_checkbox = pn.widgets.Checkbox(name="Check to Submit Feedback")
-    instance.send(pn.Row(get_input_widget, get_input_checkbox), user=name, respond=False)
+    instance.send(
+        pn.Row(get_input_widget, get_input_checkbox), user=name, respond=False
+    )
     ts = time.time()
     while True:
         if time.time() - ts > TIMEOUT:
@@ -221,7 +232,10 @@ async def check_termination_and_human_reply(
         # if the human input is empty, and the message is a termination message, then we will terminate the conversation
         reply = reply if reply or not self._is_termination_msg(message) else "exit"
     else:
-        if self._consecutive_auto_reply_counter[sender] >= self._max_consecutive_auto_reply_dict[sender]:
+        if (
+            self._consecutive_auto_reply_counter[sender]
+            >= self._max_consecutive_auto_reply_dict[sender]
+        ):
             if self.human_input_mode == "NEVER":
                 reply = "exit"
             else:
@@ -280,7 +294,9 @@ async def format_code(code_to_format: str) -> str:
     filename = f"temp_code_{int(time.time())}_{random.randint(10000, 99999)}.py"
     with open(filename, "w") as file:
         file.write(code_to_format)
-    isort.file(filename, profile="black", known_first_party=["autogen"], float_to_top=True)
+    isort.file(
+        filename, profile="black", known_first_party=["autogen"], float_to_top=True
+    )
 
     formatted_code = ""
     with open(filename, "r") as file:
@@ -358,7 +374,8 @@ agent = RetrieveUserProxyAgent(
 
 """
             _code = _code.replace(
-                """'chromadb.PersistentClient(path=".chromadb")'""", "chromadb.PersistentClient(path='.chromadb')"
+                """'chromadb.PersistentClient(path=".chromadb")'""",
+                "chromadb.PersistentClient(path='.chromadb')",
             )
         elif isinstance(agent, GPTAssistantAgent):
             _code = f"""from auotgen.agentchat.contrib.gpt_assistant_agent import GPTAssistantAgent
@@ -429,6 +446,7 @@ agent = AssistantAgent(
         code += _code + "\n" + "agents.append(agent)\n\n"
 
     _code = """
+init_sender = None
 for agent in agents:
     if "UserProxy" in str(type(agent)):
         init_sender = agent