Initial commit: Startup Idea Validator app (cleaned - removed sensitive files)

.gitattributes

@@ -0,0 +1,35 @@
+*.7z filter=lfs diff=lfs merge=lfs -text
+*.arrow filter=lfs diff=lfs merge=lfs -text
+*.bin filter=lfs diff=lfs merge=lfs -text
+*.bz2 filter=lfs diff=lfs merge=lfs -text
+*.ckpt filter=lfs diff=lfs merge=lfs -text
+*.ftz filter=lfs diff=lfs merge=lfs -text
+*.gz filter=lfs diff=lfs merge=lfs -text
+*.h5 filter=lfs diff=lfs merge=lfs -text
+*.joblib filter=lfs diff=lfs merge=lfs -text
+*.lfs.* filter=lfs diff=lfs merge=lfs -text
+*.mlmodel filter=lfs diff=lfs merge=lfs -text
+*.model filter=lfs diff=lfs merge=lfs -text
+*.msgpack filter=lfs diff=lfs merge=lfs -text
+*.npy filter=lfs diff=lfs merge=lfs -text
+*.npz filter=lfs diff=lfs merge=lfs -text
+*.onnx filter=lfs diff=lfs merge=lfs -text
+*.ot filter=lfs diff=lfs merge=lfs -text
+*.parquet filter=lfs diff=lfs merge=lfs -text
+*.pb filter=lfs diff=lfs merge=lfs -text
+*.pickle filter=lfs diff=lfs merge=lfs -text
+*.pkl filter=lfs diff=lfs merge=lfs -text
+*.pt filter=lfs diff=lfs merge=lfs -text
+*.pth filter=lfs diff=lfs merge=lfs -text
+*.rar filter=lfs diff=lfs merge=lfs -text
+*.safetensors filter=lfs diff=lfs merge=lfs -text
+saved_model/**/* filter=lfs diff=lfs merge=lfs -text
+*.tar.* filter=lfs diff=lfs merge=lfs -text
+*.tar filter=lfs diff=lfs merge=lfs -text
+*.tflite filter=lfs diff=lfs merge=lfs -text
+*.tgz filter=lfs diff=lfs merge=lfs -text
+*.wasm filter=lfs diff=lfs merge=lfs -text
+*.xz filter=lfs diff=lfs merge=lfs -text
+*.zip filter=lfs diff=lfs merge=lfs -text
+*.zst filter=lfs diff=lfs merge=lfs -text
+*tfevents* filter=lfs diff=lfs merge=lfs -text

.gitignore

@@ -0,0 +1,85 @@
+# Environment variables and secrets
+.env
+.env.local
+.env.development.local
+.env.test.local
+.env.production.local
+
+# Python cache files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# PyInstaller
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+.hypothesis/
+.pytest_cache/
+
+# Virtual environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# IDE files
+.vscode/
+.idea/
+*.swp
+*.swo
+*~
+
+# OS files
+.DS_Store
+.DS_Store?
+._*
+.Spotlight-V100
+.Trashes
+ehthumbs.db
+Thumbs.db
+
+# Streamlit specific
+.streamlit/
+
+# Logs
+*.log
+
+# Temporary files
+*.tmp
+*.bak 

Dockerfile

@@ -0,0 +1,21 @@
+FROM python:3.10-slim
+
+WORKDIR /app
+
+RUN apt-get update && apt-get install -y \
+    build-essential \
+    curl \
+    software-properties-common \
+    git \
+    && rm -rf /var/lib/apt/lists/*
+
+COPY requirements.txt ./
+COPY src/ ./src/
+
+RUN pip3 install -r requirements.txt
+
+EXPOSE 8501
+
+HEALTHCHECK CMD curl --fail http://localhost:8501/_stcore/health
+
+ENTRYPOINT ["streamlit", "run", "src/streamlit_app.py", "--server.port=8501", "--server.address=0.0.0.0"] 

README.md

@@ -0,0 +1,65 @@
+# 🚀 Startup Idea Validator - Streamlit App
+
+A comprehensive AI-powered tool for validating startup ideas with market research and competitive analysis.
+
+## Features
+
+- **🎯 Idea Clarification**: AI assessment of originality, mission, and objectives
+- **📊 Market Research**: TAM/SAM/SOM analysis and customer segmentation  
+- **🏢 Competitor Analysis**: SWOT analysis and positioning assessment
+- **📋 Validation Report**: Executive summary with strategic recommendations
+
+## Setup & Installation
+
+1. **Install Dependencies**:
+   ```bash
+   pip install -r requirements.txt
+   ```
+
+2. **Set Environment Variables**:
+   ```bash
+   export OPENAI_API_KEY="your-openai-api-key"
+   export ATLA_INSIGHTS_TOKEN="your-atla-insights-token"
+   export GOOGLE_API_KEY="your-google-api-key"  # For search functionality
+   ```
+
+3. **Run the Streamlit App**:
+   ```bash
+   streamlit run streamlit_app.py
+   ```
+
+4. **Open Your Browser**:
+   The app will automatically open at `http://localhost:8501`
+
+## Usage
+
+1. **Enter Your Startup Idea**: Describe your startup idea in detail in the text area
+2. **Add Context** (Optional): Provide additional information about your target market or business model
+3. **Click "Validate My Idea"**: The AI agents will analyze your idea through multiple phases
+4. **Review Results**: Get a comprehensive validation report with recommendations
+5. **Download Report**: Save the validation report as a markdown file
+
+## Example Startup Ideas
+
+- AI-powered personal finance coach for millennials
+- Sustainable packaging solutions for e-commerce
+- Virtual reality fitness platform for remote workers
+- Marketplace for local artisan food products
+- Smart home energy optimization system
+
+## Requirements
+
+- Python 3.8+
+- Valid OpenAI API key
+- Atla Insights token (for monitoring)
+- Google API key (for search functionality)
+
+## Troubleshooting
+
+- **API Errors**: Ensure all environment variables are set correctly
+- **Slow Performance**: The validation process typically takes 2-5 minutes
+- **Connection Issues**: Check your internet connection and API limits
+
+## Note
+
+This validation is for informational purposes only. Conduct additional due diligence before making investment decisions. 

requirements.txt

@@ -0,0 +1,38 @@
+# Core Framework
+agno>=1.7.5
+streamlit>=1.47.0
+
+# AI/ML Libraries  
+openai>=1.97.1
+anthropic>=0.58.2
+groq>=0.30.0
+google-generativeai>=0.8.5
+
+# Search and Research Tools
+google-search-results>=2.4.2
+duckduckgo-search>=8.1.1
+exa-py>=1.14.18
+googlesearch-python>=1.3.0
+pycountry>=24.6.1
+
+# Monitoring and Observability
+atla-insights[openai]>=0.0.11
+atla-insights[agno]>=0.0.11
+
+# Core Python Libraries
+pydantic>=2.11.7
+pydantic-settings>=2.10.1
+python-dotenv>=1.1.1
+httpx>=0.28.1
+requests>=2.32.4
+
+# Data and UI
+pandas>=2.3.1
+numpy>=1.24.0,<2.0.0
+rich>=14.0.0
+
+# Async Support
+nest-asyncio>=1.6.0
+
+# Database (if needed)
+sqlalchemy>=2.0.41

src/streamlit_app.py

@@ -0,0 +1,276 @@
+import streamlit as st
+import asyncio
+from workflows_v2 import startup_validation_workflow
+import time
+
+# Real-time progress tracking class
+class StreamlitProgressTracker:
+    def __init__(self):
+        self.progress_container = None
+        self.status_text = None
+        self.progress_bar = None
+        self.log_container = None
+        self.current_phase = 0
+        self.total_phases = 4
+        
+    def setup_ui(self):
+        self.progress_container = st.container()
+        with self.progress_container:
+            self.status_text = st.empty()
+            self.progress_bar = st.progress(0)
+            self.log_container = st.container()
+    
+    def update_progress(self, message):
+        """Called by workflow for each progress update"""
+        
+        # Track phases based on message content
+        if "PHASE 1:" in message:
+            self.current_phase = 1
+        elif "PHASE 2:" in message:
+            self.current_phase = 2
+        elif "PHASE 3:" in message:
+            self.current_phase = 3
+        elif "PHASE 4:" in message:
+            self.current_phase = 4
+        
+        # Update progress bar
+        progress = (self.current_phase / self.total_phases) * 100
+        self.progress_bar.progress(int(progress))
+        
+        # Update status
+        if "PHASE" in message and ":" in message:
+            self.status_text.info(f"🔄 {message}")
+        elif "✅" in message:
+            self.status_text.success(f"{message}")
+        else:
+            self.status_text.info(f"🔄 {message}")
+        
+        # Add to log (skip the "=" separator lines)
+        if message and message.strip() and not all(c == '=' for c in message.strip()):
+            with self.log_container:
+                st.text(message)
+    
+    def complete(self):
+        self.progress_bar.progress(100)
+        self.status_text.success("✅ Validation completed!")
+
+def main():
+    st.set_page_config(
+        page_title="Startup Idea Validator",
+        page_icon="🚀",
+        layout="wide",
+        initial_sidebar_state="expanded"
+    )
+    
+    # Custom CSS for better styling
+    st.markdown("""
+    <style>
+    .main-header {
+        font-size: 3rem;
+        font-weight: bold;
+        text-align: center;
+        margin-bottom: 2rem;
+        background: linear-gradient(90deg, #667eea 0%, #764ba2 100%);
+        -webkit-background-clip: text;
+        -webkit-text-fill-color: transparent;
+    }
+    .stButton > button {
+        background: linear-gradient(90deg, #667eea 0%, #764ba2 100%);
+        color: white;
+        border: none;
+        padding: 0.5rem 2rem;
+        border-radius: 10px;
+        font-weight: bold;
+    }
+    .result-section {
+        background-color: #f8f9fa;
+        padding: 2rem;
+        border-radius: 15px;
+        border-left: 5px solid #667eea;
+        margin: 2rem 0;
+    }
+    .log-container {
+        background-color: #f1f3f4;
+        padding: 1rem;
+        border-radius: 8px;
+        font-family: monospace;
+        font-size: 0.9rem;
+        max-height: 300px;
+        overflow-y: auto;
+        border: 1px solid #ddd;
+    }
+    </style>
+    """, unsafe_allow_html=True)
+    
+    # Header
+    st.markdown('<h1 class="main-header">🚀 Startup Idea Validator</h1>', unsafe_allow_html=True)
+
+    # Subtitle with demo and guide links
+    st.markdown("""
+    <div style='text-align: center; margin-bottom: 1rem; color: #666;'>
+        <p>🔍 <a href="https://app.atla-ai.com/app/atla-demo-802mg?startDate=2025-07-25&endDate=2025-07-31" target="_blank">View your traces on Atla Insights</a> | 
+        📚 <a href="https://www.atla-ai.com/find-and-fix-ai-agent-failures" target="_blank">Understand the Insights platform</a></p>
+        <p style='font-size: 0.85rem; margin-top: 0.5rem;'>🛠️ <a href="https://docs.agno.com/introduction" target="_blank" style="color: #667eea; text-decoration: none;">Built with Agno</a></p>
+    </div>
+    """, unsafe_allow_html=True)
+
+    st.markdown("---")
+    
+    # Sidebar with information
+    with st.sidebar:
+        st.markdown("## 📋 About This Tool")
+        st.markdown("""
+        This AI-powered tool validates your startup idea through:
+        
+        🎯 **Idea Clarification**
+        - Originality assessment
+        - Mission definition
+        - Objective setting
+        
+        📊 **Market Research**
+        - TAM/SAM/SOM analysis
+        - Customer segmentation
+        - Market trends
+        
+        🏢 **Competitor Analysis**
+        - SWOT analysis
+        - Positioning assessment
+        - Market gaps
+        
+        📋 **Validation Report**
+        - Executive summary
+        - Strategic recommendations
+        - Next steps
+        """)
+        
+        st.markdown("---")
+        st.markdown("💡 **Tip:** Be as specific as possible about your startup idea for better results!")
+    
+    # Main content area
+    col1, col2 = st.columns([2, 1])
+    
+    with col1:
+        st.markdown("## 💡 Tell us about your startup idea")
+        
+        # Input form
+        with st.form("startup_form", clear_on_submit=False):
+            # Get default value from session state if an example was selected
+            default_value = st.session_state.get('selected_example', '')
+            
+            startup_idea = st.text_area(
+                "Describe your startup idea in detail:",
+                value=default_value,
+                height=150,
+                placeholder="e.g., A marketplace for Christmas Ornaments made from leather that connects artisans with customers looking for unique holiday decorations...",
+                help="The more detailed your description, the better the validation will be."
+            )
+            
+            submitted = st.form_submit_button("🔍 Validate My Idea", use_container_width=True)
+    
+    with col2:
+        st.markdown("## 🎯 Quick Examples")
+        st.markdown("*Click any example to populate the idea field*")
+        
+        examples = [
+            "AI-powered personal finance coach for millennials",
+            "Sustainable packaging solutions for e-commerce",
+            "Virtual reality fitness platform for remote workers",
+            "Marketplace for local artisan food products",
+            "Smart home energy optimization system"
+        ]
+        
+        for i, example in enumerate(examples):
+            if st.button(f"💡 {example}", key=f"example_{i}", help="Click to populate the startup idea field"):
+                st.session_state.selected_example = example
+                st.rerun()
+    
+    # Clear the selected example from session state after form renders
+    if 'selected_example' in st.session_state and startup_idea:
+        if startup_idea == st.session_state.selected_example:
+            # Example has been loaded into the form, show success message
+            st.success(f"✅ Example loaded: {startup_idea[:50]}...")
+        # Keep the example in session state until form is submitted
+    
+    # Process the form submission
+    if submitted and startup_idea:
+        # Clear the selected example when submitting
+        if 'selected_example' in st.session_state:
+            del st.session_state.selected_example
+            
+        st.markdown("---")
+        st.markdown("## 🔄 Real-time Validation Progress")
+        
+        # Initialize progress tracker
+        tracker = StreamlitProgressTracker()
+        tracker.setup_ui()
+        
+        try:
+            # Prepare the message
+            message = "Please validate this startup idea with comprehensive market research and competitive analysis"
+            
+            # Run the workflow with real-time progress
+            async def run_validation():
+                return await startup_validation_workflow.arun(
+                    message=message,
+                    startup_idea=startup_idea,
+                    progress_callback=tracker.update_progress  # Pass the real-time callback
+                )
+            
+            # Execute the async workflow
+            result = asyncio.run(run_validation())
+            
+            # Complete progress
+            tracker.complete()
+            
+            # Display results with improved formatting
+            st.markdown("---")
+            st.markdown("## 📊 Validation Results")
+            
+            # Extract clean content from WorkflowRunResponse
+            validation_content = ""
+            
+            if hasattr(result, 'content') and result.content:
+                validation_content = result.content
+            elif hasattr(result, 'response') and result.response:
+                validation_content = result.response
+            else:
+                validation_content = str(result)
+            
+            # Clean up content if needed
+            if validation_content:
+                validation_content = validation_content.replace('\\n', '\n')
+                validation_content = validation_content.replace('\\"', '"')
+            
+            # Display in a formatted code block for consistent appearance
+            st.code(validation_content, language="markdown")
+            
+            # Add download button for the report
+            st.download_button(
+                label="📥 Download Report",
+                data=validation_content,
+                file_name=f"startup_validation_{startup_idea[:30].replace(' ', '_')}.md",
+                mime="text/markdown"
+            )
+            
+        except Exception as e:
+            st.error(f"❌ An error occurred during validation: {str(e)}")
+            st.error("Please check your environment variables and try again.")
+            
+            # Display error details in expander
+            with st.expander("🔍 Error Details"):
+                st.code(str(e))
+    
+    elif submitted and not startup_idea:
+        st.warning("⚠️ Please enter a startup idea before submitting.")
+    
+    # Footer
+    st.markdown("---")
+    st.markdown("""
+    <div style='text-align: center; color: #666; font-size: 0.9rem;'>
+        <p>🔬 Powered by AI agents and comprehensive market research</p>
+        <p>⚠️ This validation is for informational purposes only. Conduct additional due diligence before making investment decisions.</p>
+    </div>
+    """, unsafe_allow_html=True)
+
+if __name__ == "__main__":
+    main() 

src/workflows_v2.py

@@ -0,0 +1,461 @@
+import asyncio
+from typing import Any
+
+from agno.agent import Agent
+from agno.models.openai import OpenAIChat
+from agno.tools.googlesearch import GoogleSearchTools
+from agno.utils.pprint import pprint_run_response
+from agno.workflow.v2.types import WorkflowExecutionInput
+from agno.workflow.v2.workflow import Workflow
+from pydantic import BaseModel, Field
+
+from dotenv import load_dotenv
+import os
+
+script_dir = os.path.dirname(os.path.abspath(__file__))
+env_path = os.path.join(script_dir, '.env')
+load_dotenv(env_path)
+
+# --- Atla Insights Configuration ---
+from atla_insights import configure, instrument, instrument_agno, instrument_openai, mark_success, mark_failure, tool
+
+# Define metadata for tracing
+metadata = {
+    "model": "gpt-4o",
+    "prompt": "v1.1",
+    "environment": "prod",
+    "agent_name": "Startup Idea Validator"
+}
+
+# Configure Atla Insights with metadata - REQUIRED FIRST
+configure(token=os.getenv("ATLA_INSIGHTS_TOKEN"), metadata=metadata)
+
+# Instrument based on detected framework and LLM provider
+instrument_agno("openai")  # Agno framework with OpenAI
+instrument_openai()        # OpenAI LLM provider
+
+# --- Response models ---
+class IdeaClarification(BaseModel):
+    originality: str = Field(..., description="Originality of the idea.")
+    mission: str = Field(..., description="Mission of the company.")
+    objectives: str = Field(..., description="Objectives of the company.")
+
+
+class MarketResearch(BaseModel):
+    total_addressable_market: str = Field(
+        ..., description="Total addressable market (TAM) with specific dollar amount."
+    )
+    total_addressable_market_calculation: str = Field(
+        ..., description="Step-by-step calculation methodology used to derive TAM."
+    )
+    total_addressable_market_sources: str = Field(
+        ..., description="Specific data sources and citations used for TAM calculation."
+    )
+    serviceable_available_market: str = Field(
+        ..., description="Serviceable available market (SAM) with specific dollar amount."
+    )
+    serviceable_available_market_calculation: str = Field(
+        ..., description="Step-by-step calculation methodology used to derive SAM from TAM."
+    )
+    serviceable_obtainable_market: str = Field(
+        ..., description="Serviceable obtainable market (SOM) with specific dollar amount."
+    )
+    serviceable_obtainable_market_calculation: str = Field(
+        ..., description="Step-by-step calculation methodology used to derive SOM from SAM."
+    )
+    market_size_validation: str = Field(
+        ..., description="Self-validation check: Does SOM < SAM < TAM? Are calculations logical and consistent?"
+    )
+    target_customer_segments: str = Field(..., description="Target customer segments with detailed demographics, needs, and market sizes.")
+    data_quality_assessment: str = Field(
+        ..., description="Assessment of the reliability and recency of the data sources used."
+    )
+
+
+class CompetitorAnalysis(BaseModel):
+    competitors: str = Field(..., description="List of identified competitors.")
+    swot_analysis: str = Field(..., description="SWOT analysis for each competitor.")
+    positioning: str = Field(
+        ..., description="Startup's potential positioning relative to competitors."
+    )
+
+
+class ValidationReport(BaseModel):
+    executive_summary: str = Field(
+        ..., description="Executive summary of the validation."
+    )
+    idea_assessment: str = Field(..., description="Assessment of the startup idea.")
+    market_opportunity: str = Field(..., description="Market opportunity analysis.")
+    competitive_landscape: str = Field(
+        ..., description="Competitive landscape overview."
+    )
+    recommendations: str = Field(..., description="Strategic recommendations.")
+    next_steps: str = Field(..., description="Recommended next steps.")
+
+
+# --- Agents ---
+idea_clarifier_agent = Agent(
+    name="Idea Clarifier",
+    model=OpenAIChat(id="gpt-4o"),
+    instructions=[
+        "Given a user's startup idea, your goal is to refine that idea.",
+        "Evaluate the originality of the idea by comparing it with existing concepts.",
+        "Define the mission and objectives of the startup.",
+        "Provide clear, actionable insights about the core business concept.",
+    ],
+    add_history_to_messages=True,
+    add_datetime_to_instructions=True,
+    response_model=IdeaClarification,
+    debug_mode=False,
+)
+
+market_research_agent = Agent(
+    name="Market Research Agent",
+    model=OpenAIChat(id="gpt-4o"),
+    tools=[GoogleSearchTools()],
+    instructions=[
+        "You are provided with a startup idea and the company's mission and objectives.",
+        "Estimate the total addressable market (TAM), serviceable available market (SAM), and serviceable obtainable market (SOM).",
+        "Define target customer segments and their characteristics.",
+        "Search the web for resources and data to support your analysis.",
+        "Provide specific market size estimates with supporting data sources.",
+    ],
+    add_history_to_messages=True,
+    add_datetime_to_instructions=True,
+    response_model=MarketResearch,
+)
+
+competitor_analysis_agent = Agent(
+    name="Competitor Analysis Agent",
+    model=OpenAIChat(id="gpt-4o"),
+    tools=[GoogleSearchTools()],
+    instructions=[
+        "You are provided with a startup idea and market research data.",
+        "Identify existing competitors in the market.",
+        "Perform Strengths, Weaknesses, Opportunities, and Threats (SWOT) analysis for each competitor.",
+        "Assess the startup's potential positioning relative to competitors.",
+        "Search for recent competitor information and market positioning.",
+    ],
+    add_history_to_messages=True,
+    add_datetime_to_instructions=True,
+    response_model=CompetitorAnalysis,
+    debug_mode=False,
+)
+
+report_agent = Agent(
+    name="Report Generator",
+    model=OpenAIChat(id="gpt-4o"),
+    instructions=[
+        "You are provided with comprehensive data about a startup idea including clarification, market research, and competitor analysis.",
+        "Synthesize all information into a comprehensive validation report.",
+        "Provide clear executive summary, assessment, and actionable recommendations.",
+        "Structure the report professionally with clear sections and insights.",
+        "Include specific next steps for the entrepreneur.",
+    ],
+    add_history_to_messages=True,
+    add_datetime_to_instructions=True,
+    response_model=ValidationReport,
+    debug_mode=False,
+)
+
+
+# --- Execution function ---
+@instrument("Startup Idea Validation Workflow")
+async def startup_validation_execution(
+    workflow: Workflow,
+    execution_input: WorkflowExecutionInput,
+    startup_idea: str,
+    progress_callback=None,
+    **kwargs: Any,
+) -> str:
+    """Execute the complete startup idea validation workflow"""
+
+    # Get inputs
+    message: str = execution_input.message
+    idea: str = startup_idea
+
+    if not idea:
+        mark_failure()
+        return "❌ No startup idea provided"
+
+    if progress_callback:
+        progress_callback(f"🚀 Starting startup idea validation for: {idea}")
+        progress_callback(f"💡 Validation request: {message}")
+    else:
+        print(f"🚀 Starting startup idea validation for: {idea}")
+        print(f"💡 Validation request: {message}")
+
+    # Phase 1: Idea Clarification
+    if progress_callback:
+        progress_callback(f"\n🎯 PHASE 1: IDEA CLARIFICATION & REFINEMENT")
+        progress_callback("=" * 60)
+    else:
+        print(f"\n🎯 PHASE 1: IDEA CLARIFICATION & REFINEMENT")
+        print("=" * 60)
+
+    clarification_prompt = f"""
+    {message}
+    
+    Please analyze and refine the following startup idea:
+    
+    STARTUP IDEA: {idea}
+    
+    Evaluate:
+    1. The originality of this idea compared to existing solutions
+    2. Define a clear mission statement for this startup
+    3. Outline specific, measurable objectives
+    
+    Provide insights on how to strengthen and focus the core concept.
+    """
+
+    if progress_callback:
+        progress_callback(f"🔍 Analyzing and refining the startup concept...")
+    else:
+        print(f"🔍 Analyzing and refining the startup concept...")
+
+    try:
+        clarification_result = await idea_clarifier_agent.arun(clarification_prompt)
+        idea_clarification = clarification_result.content
+
+        if progress_callback:
+            progress_callback(f"✅ Idea clarification completed")
+            progress_callback(f"📝 Mission: {idea_clarification.mission[:100]}...")
+        else:
+            print(f"✅ Idea clarification completed")
+            print(f"📝 Mission: {idea_clarification.mission[:100]}...")
+
+    except Exception as e:
+        mark_failure()
+        return f"❌ Failed to clarify idea: {str(e)}"
+
+    # Phase 2: Market Research
+    if progress_callback:
+        progress_callback(f"\n📊 PHASE 2: MARKET RESEARCH & ANALYSIS")
+        progress_callback("=" * 60)
+    else:
+        print(f"\n📊 PHASE 2: MARKET RESEARCH & ANALYSIS")
+        print("=" * 60)
+
+    market_research_prompt = f"""
+    Based on the refined startup idea and clarification below, conduct comprehensive market research:
+    
+    STARTUP IDEA: {idea}
+    ORIGINALITY: {idea_clarification.originality}
+    MISSION: {idea_clarification.mission}
+    OBJECTIVES: {idea_clarification.objectives}
+    
+    Please research and provide:
+    1. Total Addressable Market (TAM) - overall market size
+    2. Serviceable Available Market (SAM) - portion you could serve
+    3. Serviceable Obtainable Market (SOM) - realistic market share
+    4. Target customer segments with detailed characteristics
+    
+    Use web search to find current market data and trends.
+    """
+
+    if progress_callback:
+        progress_callback(f"📈 Researching market size and customer segments...")
+    else:
+        print(f"📈 Researching market size and customer segments...")
+
+    try:
+        market_result = await market_research_agent.arun(market_research_prompt)
+        market_research = market_result.content
+
+        if progress_callback:
+            progress_callback(f"✅ Market research completed")
+            progress_callback(f"🎯 TAM: {market_research.total_addressable_market[:100]}...")
+        else:
+            print(f"✅ Market research completed")
+            print(f"🎯 TAM: {market_research.total_addressable_market[:100]}...")
+
+    except Exception as e:
+        mark_failure()
+        return f"❌ Failed to complete market research: {str(e)}"
+
+    # Phase 3: Competitor Analysis
+    if progress_callback:
+        progress_callback(f"\n🏢 PHASE 3: COMPETITIVE LANDSCAPE ANALYSIS")
+        progress_callback("=" * 60)
+    else:
+        print(f"\n🏢 PHASE 3: COMPETITIVE LANDSCAPE ANALYSIS")
+        print("=" * 60)
+
+    competitor_prompt = f"""
+    Based on the startup idea and market research below, analyze the competitive landscape:
+    
+    STARTUP IDEA: {idea}
+    TAM: {market_research.total_addressable_market}
+    SAM: {market_research.serviceable_available_market}
+    SOM: {market_research.serviceable_obtainable_market}
+    TARGET SEGMENTS: {market_research.target_customer_segments}
+    
+    Please research and provide:
+    1. Identify direct and indirect competitors
+    2. SWOT analysis for each major competitor
+    3. Assessment of startup's potential competitive positioning
+    4. Market gaps and opportunities
+    
+    Use web search to find current competitor information.
+    """
+
+    if progress_callback:
+        progress_callback(f"🔎 Analyzing competitive landscape...")
+    else:
+        print(f"🔎 Analyzing competitive landscape...")
+
+    try:
+        competitor_result = await competitor_analysis_agent.arun(competitor_prompt)
+        competitor_analysis = competitor_result.content
+
+        if progress_callback:
+            progress_callback(f"✅ Competitor analysis completed")
+            progress_callback(f"🏆 Positioning: {competitor_analysis.positioning[:100]}...")
+        else:
+            print(f"✅ Competitor analysis completed")
+            print(f"🏆 Positioning: {competitor_analysis.positioning[:100]}...")
+
+    except Exception as e:
+        mark_failure()
+        return f"❌ Failed to complete competitor analysis: {str(e)}"
+
+    # Phase 4: Final Validation Report
+    if progress_callback:
+        progress_callback(f"\n📋 PHASE 4: COMPREHENSIVE VALIDATION REPORT")
+        progress_callback("=" * 60)
+    else:
+        print(f"\n📋 PHASE 4: COMPREHENSIVE VALIDATION REPORT")
+        print("=" * 60)
+
+    report_prompt = f"""
+    Synthesize all the research and analysis into a comprehensive startup validation report:
+    
+    STARTUP IDEA: {idea}
+    
+    IDEA CLARIFICATION:
+    - Originality: {idea_clarification.originality}
+    - Mission: {idea_clarification.mission}
+    - Objectives: {idea_clarification.objectives}
+    
+    MARKET RESEARCH:
+    - TAM: {market_research.total_addressable_market}
+    - SAM: {market_research.serviceable_available_market}
+    - SOM: {market_research.serviceable_obtainable_market}
+    - Target Segments: {market_research.target_customer_segments}
+    
+    COMPETITOR ANALYSIS:
+    - Competitors: {competitor_analysis.competitors}
+    - SWOT: {competitor_analysis.swot_analysis}
+    - Positioning: {competitor_analysis.positioning}
+    
+    Create a professional validation report with:
+    1. Executive summary
+    2. Idea assessment (strengths/weaknesses)
+    3. Market opportunity analysis
+    4. Competitive landscape overview
+    5. Strategic recommendations
+    6. Specific next steps for the entrepreneur
+    """
+
+    if progress_callback:
+        progress_callback(f"📝 Generating comprehensive validation report...")
+    else:
+        print(f"📝 Generating comprehensive validation report...")
+
+    try:
+        final_result = await report_agent.arun(report_prompt)
+        validation_report = final_result.content
+
+        if progress_callback:
+            progress_callback(f"✅ Validation report completed")
+        else:
+            print(f"✅ Validation report completed")
+
+    except Exception as e:
+        mark_failure()
+        return f"❌ Failed to generate final report: {str(e)}"
+
+    # Final summary
+    summary = f"""
+    🎉 STARTUP IDEA VALIDATION COMPLETED!
+    
+    📊 Validation Summary:
+    • Startup Idea: {idea}
+    • Idea Clarification: ✅ Completed
+    • Market Research: ✅ Completed
+    • Competitor Analysis: ✅ Completed
+    • Final Report: ✅ Generated
+    
+    📈 Key Market Insights:
+    • TAM: {market_research.total_addressable_market[:150]}...
+    • Target Segments: {market_research.target_customer_segments[:150]}...
+    
+    🏆 Competitive Positioning:
+    {competitor_analysis.positioning[:200]}...
+    
+    📋 COMPREHENSIVE VALIDATION REPORT:
+    
+    ## Executive Summary
+    {validation_report.executive_summary}
+    
+    ## Idea Assessment
+    {validation_report.idea_assessment}
+    
+    ## Market Opportunity
+    {validation_report.market_opportunity}
+    
+    ## Competitive Landscape
+    {validation_report.competitive_landscape}
+    
+    ## Strategic Recommendations
+    {validation_report.recommendations}
+    
+    ## Next Steps
+    {validation_report.next_steps}
+    
+    ⚠️ Disclaimer: This validation is for informational purposes only. Conduct additional due diligence before making investment decisions.
+    """
+
+    # Mark successful completion
+    mark_success()
+    return summary
+
+
+# --- Workflow definition ---
+startup_validation_workflow = Workflow(
+    name="Startup Idea Validator",
+    description="Comprehensive startup idea validation with market research and competitive analysis",
+    steps=startup_validation_execution,
+    workflow_session_state={},  # Initialize empty workflow session state
+)
+
+
+if __name__ == "__main__":
+
+    async def main():
+        from rich.prompt import Prompt
+
+        # Get idea from user
+        idea = Prompt.ask(
+            "[bold]What is your startup idea?[/bold]\n✨",
+            default="A marketplace for Christmas Ornaments made from leather",
+        )
+
+        print("🧪 Testing Startup Idea Validator with New Workflow Structure")
+        print("=" * 70)
+
+        try:
+            result = await startup_validation_workflow.arun(
+                message="Please validate this startup idea with comprehensive market research and competitive analysis",
+                startup_idea=idea,
+            )
+
+            pprint_run_response(result, markdown=True)
+            mark_success()
+            
+        except Exception as e:
+            print(f"❌ Application failed: {str(e)}")
+            mark_failure()
+            raise
+
+    asyncio.run(main())