Function migrate_workflow

backend/app/api/workflow_v2.py:184–241

Migrate a workflow from state-based to tool-based agent. This helps users transition their existing workflows to the new agent.

(
    pipeline_id: str,
    connection_manager: ConnectionManager = Depends(lambda: ConnectionManager()),
    current_user: User = Depends(get_current_user)
)

@router.post("/migrate")
async def migrate_workflow(
    pipeline_id: str,
    connection_manager: ConnectionManager = Depends(lambda: ConnectionManager()),
    current_user: User = Depends(get_current_user)
) -> Dict[str, Any]:
    """
    Migrate a workflow from state-based to tool-based agent.
    
    This helps users transition their existing workflows to the new agent.
    """
    # Get both managers
    state_manager = get_enhanced_workflow_manager(connection_manager, use_tools=False)
    tools_manager = get_enhanced_workflow_manager(connection_manager, use_tools=True)
    
    # Get existing workflow
    workflow = state_manager.get_workflow(pipeline_id)
    if not workflow:
        raise HTTPException(status_code=404, detail="Workflow not found")
    
    # Create simplified message for tool-based agent
    migration_summary = []
    
    if workflow.urls:
        migration_summary.append(f"Found {len(workflow.urls)} URLs to process")
        
    if workflow.schema_fields:
        schema_desc = ", ".join([f.name for f in workflow.schema_fields])
        migration_summary.append(f"Schema fields: {schema_desc}")
        
    if workflow.generated_code:
        migration_summary.append("Has generated code ready")
        
    # Process with new agent
    message = f"""Migrate this workflow to use the new tool-based approach.
    
Current state: {workflow.phase.value}
{' '.join(migration_summary)}

Please analyze the current workflow and suggest how to proceed with the available tools."""
    
    result = await tools_manager.process_message(pipeline_id, message, current_user.username)
    
    return {
        "success": True,
        "original_workflow": {
            "phase": workflow.phase.value,
            "urls_count": len(workflow.urls),
            "schema_fields_count": len(workflow.schema_fields),
            "has_code": bool(workflow.generated_code)
        },
        "migration_result": result,
        "recommendations": [
            "Use smart_scraper for single-page extraction",
            "Use smart_crawler for multi-page scraping",
            "Use search_scraper to find new URLs",
            "The new agent handles state automatically"
        ]
    }