Create modules/parallel_executor.py

modules/parallel_executor.py

@@ -0,0 +1,28 @@
+# modules/parallel_executor.py
+import asyncio
+from modules.web_tools import search_web, summarize_url
+from modules.input_processor import InputProcessor
+
+class ParallelTaskExecutor:
+    def __init__(self):
+        self.input_processor = InputProcessor()
+
+    async def execute(self, subtasks):
+        tasks = [self._handle_subtask(st) for st in subtasks]
+        results = await asyncio.gather(*tasks)
+        return results
+
+    async def _handle_subtask(self, subtask):
+        query = subtask.get("query")
+        language = subtask.get("language", "en")
+        modality = subtask.get("modality", "text")
+
+        try:
+            if modality == "text":
+                urls = await search_web(query, language)
+                summaries = [await summarize_url(url) for url in urls]
+                return {"query": query, "results": summaries}
+            else:
+                return {"query": query, "results": f"Modality '{modality}' not supported in this environment."}
+        except Exception as e:
+            return {"query": query, "error": str(e)}