From ee4bc9e37e0393a89dc4405947b2d7c041c6fa37 Mon Sep 17 00:00:00 2001 From: harshalmore31 Date: Thu, 24 Jul 2025 22:11:31 +0530 Subject: [PATCH] updated with an example ! --- .../streaming_concurrent_workflow.py | 62 +++++++++++++++++++ 1 file changed, 62 insertions(+) create mode 100644 examples/multi_agent/concurrent_examples/streaming_concurrent_workflow.py diff --git a/examples/multi_agent/concurrent_examples/streaming_concurrent_workflow.py b/examples/multi_agent/concurrent_examples/streaming_concurrent_workflow.py new file mode 100644 index 00000000..c8dc9366 --- /dev/null +++ b/examples/multi_agent/concurrent_examples/streaming_concurrent_workflow.py @@ -0,0 +1,62 @@ +from swarms import Agent, ConcurrentWorkflow, SwarmRouter + +# Initialize market research agent +market_researcher = Agent( + agent_name="Market-Researcher", + system_prompt="""You are a market research specialist. Your tasks include: + 1. Analyzing market trends and patterns + 2. Identifying market opportunities and threats + 3. Evaluating competitor strategies + 4. Assessing customer needs and preferences + 5. Providing actionable market insights""", + model_name="claude-3-5-sonnet-20240620", + max_loops=1, + streaming_on=True, + print_on=False, +) + +# Initialize financial analyst agent +financial_analyst = Agent( + agent_name="Financial-Analyst", + system_prompt="""You are a financial analysis expert. Your responsibilities include: + 1. Analyzing financial statements + 2. Evaluating investment opportunities + 3. Assessing risk factors + 4. Providing financial forecasts + 5. Recommending financial strategies""", + model_name="claude-3-5-sonnet-20240620", + max_loops=1, + streaming_on=True, + print_on=False, +) + +# Initialize technical analyst agent +technical_analyst = Agent( + agent_name="Technical-Analyst", + system_prompt="""You are a technical analysis specialist. Your focus areas include: + 1. Analyzing price patterns and trends + 2. Evaluating technical indicators + 3. Identifying support and resistance levels + 4. Assessing market momentum + 5. Providing trading recommendations""", + model_name="claude-3-5-sonnet-20240620", + max_loops=1, + streaming_on=True, + print_on=False, +) + +# Create list of agents +agents = [market_researcher, financial_analyst, technical_analyst] + +# Initialize the concurrent workflow +workflow = ConcurrentWorkflow( + name="market-analysis-workflow", + agents=agents, + max_loops=1, + show_dashboard=True, +) + +# Run the workflow +result = workflow.run( + "Analyze Tesla (TSLA) stock from market, financial, and technical perspectives" +) \ No newline at end of file