Update main.py

main.py

@@ -9,6 +9,10 @@ class CryptoCrew:
     def __init__(self, crypto):
         self.crypto = crypto
 
+    def run(self):
+        # This method can be called from synchronous code
+        return asyncio.run(self.run_async())
+
     async def run_async(self):
         agents = CryptoAnalysisAgents()
         tasks = CryptoAnalysisTasks()
@@ -40,48 +44,18 @@ class CryptoCrew:
         )
 
         try:
-            result = await asyncio.wait_for(crew.kickoff(), timeout=600)
-        except asyncio.TimeoutError:
-            return {"summary": "Analysis timed out. Please try again with a simpler query or increased time limit."}
+            # Use asyncio.to_thread to run the synchronous crew.kickoff() in a separate thread
+            result = await asyncio.to_thread(crew.kickoff)
+        except Exception as e:
+            return {"summary": f"Analysis failed: {str(e)}. Please try again."}
 
         parsed_result = self.parse_result(result)
         return parsed_result
 
-    def run(self):
-        return asyncio.run(self.run_async())
-
     def parse_result(self, result):
-        # Attempt to extract a text summary from the result
-        try:
-            result_text = result.get_summary() # Hypothetical method; replace with actual method/attribute
-        except AttributeError:
-            # If the method or attribute doesn't exist, fall back to another way
-            result_text = str(result) # Convert to string if necessary
-
-        # Initialize the parsed result structure
-        parsed = {
-            "summary": result_text,
-            "sentiment": {
-                "overall": "Neutral",
-                "social_media": "Neutral",
-                "news": "Neutral",
-                "community": "Neutral"
-            }
-        }
-
-        # Perform sentiment extraction on the result_text
-        if "sentiment score" in result_text.lower():
-            sentiment_section = result_text.split("sentiment score")[1].split("\n")[0]
-            try:
-                sentiment_score = float(sentiment_section.strip())
-                if sentiment_score > 0.5:
-                    parsed["sentiment"]["overall"] = "Positive"
-                elif sentiment_score < -0.5:
-                    parsed["sentiment"]["overall"] = "Negative"
-            except ValueError:
-                pass # Handle the case where conversion to float fails
-
-        return parsed
+        # Implement your parse_result method here
+        # This is a placeholder implementation
+        return {"summary": str(result)}
 
 if __name__ == "__main__":
     print("## Welcome to Crypto Analysis Crew")