Yield original message type

Author: BenConstable9

text_2_sql/autogen/src/autogen_text_2_sql/custom_agents/parallel_query_solving_agent.py

@@ -75,10 +75,7 @@ async def consume_inner_messages_from_agentic_flow(
                     complete_inner_messages[identifier] = []
                 complete_inner_messages[identifier].append(inner_message)
 
-                yield TextMessage(
-                    content=json.dumps(inner_message),
-                    source=f"{self.name}-{identifier}",
-                )
+                yield inner_message
 
         inner_solving_generators = []
         complete_inner_messages = {}
@@ -102,6 +99,7 @@ async def consume_inner_messages_from_agentic_flow(
                 )
             )
 
+        logging.info("Created %i Inner Solving Generators", inner_solving_generators)
         logging.info("Starting Inner Solving Generators")
         combined_message_streams = stream.merge(*inner_solving_generators)