Update crew.py

crew.py

@@ -1,18 +1,20 @@
-from crewai import Crew
+from crewai import Crew, Process
+from langchain_openai import ChatOpenAI
+
+from agents import get_data_analyst_agent, get_trading_strategy_agent, get_execution_agent, get_risk_management_agent
+from tasks import get_data_analysis_task, get_strategy_development_task, get_execution_planning_task, get_risk_assessment_task
 
 def get_get_financial_trading_crew():
     # Define the crew with agents and tasks
-    financial_trading_crew = Crew(
-        agents=[data_analyst_agent, 
-                trading_strategy_agent, 
-                execution_agent, 
-                risk_management_agent],
-        
-        tasks=[data_analysis_task, 
-               strategy_development_task, 
-               execution_planning_task, 
-               risk_assessment_task],
-        
+    return Crew(
+        agents=[get_data_analyst_agent, 
+                get_trading_strategy_agent, 
+                get_execution_agent, 
+                get_risk_management_agent],
+        tasks=[get_data_analysis_task, 
+               get_strategy_development_task, 
+               get_execution_planning_task, 
+               get_risk_assessment_task],
         manager_llm=ChatOpenAI(model="gpt-3.5-turbo", 
                                temperature=0.7),
         process=Process.hierarchical,