update docs

docs/concepts/flows.mdx

@@ -323,91 +323,6 @@ flow.kickoff()
 
 By providing both unstructured and structured state management options, CrewAI Flows empowers developers to build AI workflows that are both flexible and robust, catering to a wide range of application requirements.
 
-## Flow Persistence
-
-The @persist decorator enables automatic state persistence in CrewAI Flows, allowing you to maintain flow state across restarts or different workflow executions. This decorator can be applied at either the class level or method level, providing flexibility in how you manage state persistence.
-
-### Class-Level Persistence
-
-When applied at the class level, the @persist decorator automatically persists all flow method states:
-
-```python
-@persist  # Using SQLiteFlowPersistence by default
-class MyFlow(Flow[MyState]):
-    @start()
-    def initialize_flow(self):
-        # This method will automatically have its state persisted
-        self.state.counter = 1
-        print("Initialized flow. State ID:", self.state.id)
-
-    @listen(initialize_flow)
-    def next_step(self):
-        # The state (including self.state.id) is automatically reloaded
-        self.state.counter += 1
-        print("Flow state is persisted. Counter:", self.state.counter)
-```
-
-### Method-Level Persistence
-
-For more granular control, you can apply @persist to specific methods:
-
-```python
-class AnotherFlow(Flow[dict]):
-    @persist  # Persists only this method's state
-    @start()
-    def begin(self):
-        if "runs" not in self.state:
-            self.state["runs"] = 0
-        self.state["runs"] += 1
-        print("Method-level persisted runs:", self.state["runs"])
-```
-
-### How It Works
-
-1. **Unique State Identification**
-   - Each flow state automatically receives a unique UUID
-   - The ID is preserved across state updates and method calls
-   - Supports both structured (Pydantic BaseModel) and unstructured (dictionary) states
-
-2. **Default SQLite Backend**
-   - SQLiteFlowPersistence is the default storage backend
-   - States are automatically saved to a local SQLite database
-   - Robust error handling ensures clear messages if database operations fail
-
-3. **Error Handling**
-   - Comprehensive error messages for database operations
-   - Automatic state validation during save and load
-   - Clear feedback when persistence operations encounter issues
-
-### Important Considerations
-
-- **State Types**: Both structured (Pydantic BaseModel) and unstructured (dictionary) states are supported
-- **Automatic ID**: The `id` field is automatically added if not present
-- **State Recovery**: Failed or restarted flows can automatically reload their previous state
-- **Custom Implementation**: You can provide your own FlowPersistence implementation for specialized storage needs
-
-### Technical Advantages
-
-1. **Precise Control Through Low-Level Access**
-   - Direct access to persistence operations for advanced use cases
-   - Fine-grained control via method-level persistence decorators
-   - Built-in state inspection and debugging capabilities
-   - Full visibility into state changes and persistence operations
-
-2. **Enhanced Reliability**
-   - Automatic state recovery after system failures or restarts
-   - Transaction-based state updates for data integrity
-   - Comprehensive error handling with clear error messages
-   - Robust validation during state save and load operations
-
-3. **Extensible Architecture**
-   - Customizable persistence backend through FlowPersistence interface
-   - Support for specialized storage solutions beyond SQLite
-   - Compatible with both structured (Pydantic) and unstructured (dict) states
-   - Seamless integration with existing CrewAI flow patterns
-
-The persistence system's architecture emphasizes technical precision and customization options, allowing developers to maintain full control over state management while benefiting from built-in reliability features.
-
 ## Flow Control
 
 ### Conditional Logic: `or`

docs/concepts/knowledge.mdx

@@ -288,7 +288,6 @@ The `embedder` parameter supports various embedding model providers that include
 - `ollama`: Local embeddings with Ollama
 - `vertexai`: Google Cloud VertexAI embeddings
 - `cohere`: Cohere's embedding models
-- `voyageai`: VoyageAI's embedding models
 - `bedrock`: AWS Bedrock embeddings
 - `huggingface`: Hugging Face models
 - `watson`: IBM Watson embeddings

docs/concepts/memory.mdx

@@ -293,26 +293,6 @@ my_crew = Crew(
     }
 )
 ```
-### Using VoyageAI embeddings
-
-```python Code
-from crewai import Crew, Agent, Task, Process
-
-my_crew = Crew(
-    agents=[...],
-    tasks=[...],
-    process=Process.sequential,
-    memory=True,
-    verbose=True,
-    embedder={
-        "provider": "voyageai",
-        "config": {
-            "api_key": "YOUR_API_KEY",
-            "model_name": "<model_name>"
-        }
-    }
-)
-```
 ### Using HuggingFace embeddings
 
 ```python Code

docs/how-to/llm-connections.mdx

@@ -23,7 +23,6 @@ LiteLLM supports a wide range of providers, including but not limited to:
 - Azure OpenAI
 - AWS (Bedrock, SageMaker)
 - Cohere
-- VoyageAI
 - Hugging Face
 - Ollama
 - Mistral AI

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "crewai"
-version = "0.98.0"
+version = "0.95.0"
 description = "Cutting-edge framework for orchestrating role-playing, autonomous AI agents. By fostering collaborative intelligence, CrewAI empowers agents to work together seamlessly, tackling complex tasks."
 readme = "README.md"
 requires-python = ">=3.10,<3.13"
@@ -13,20 +13,25 @@ dependencies = [
     "openai>=1.13.3",
     "litellm==1.57.4",
     "instructor>=1.3.3",
+
     # Text Processing
     "pdfplumber>=0.11.4",
     "regex>=2024.9.11",
+
     # Telemetry and Monitoring
     "opentelemetry-api>=1.22.0",
     "opentelemetry-sdk>=1.22.0",
     "opentelemetry-exporter-otlp-proto-http>=1.22.0",
+
     # Data Handling
     "chromadb>=0.5.23",
     "openpyxl>=3.1.5",
     "pyvis>=0.3.2",
+
     # Authentication and Security
     "auth0-python>=4.7.1",
     "python-dotenv>=1.0.0",
+
     # Configuration and Utils
     "click>=8.1.7",
     "appdirs>=1.4.4",
@@ -35,7 +40,7 @@ dependencies = [
     "uv>=0.4.25",
     "tomli-w>=1.1.0",
     "tomli>=2.0.2",
-    "blinker>=1.9.0",
+    "blinker>=1.9.0"
 ]
 
 [project.urls]
@@ -44,7 +49,7 @@ Documentation = "https://docs.crewai.com"
 Repository = "https://github.com/crewAIInc/crewAI"
 
 [project.optional-dependencies]
-tools = ["crewai-tools>=0.32.1"]
+tools = ["crewai-tools>=0.25.5"]
 embeddings = [
     "tiktoken~=0.7.0"
 ]

src/crewai/__init__.py

@@ -14,7 +14,7 @@ warnings.filterwarnings(
     category=UserWarning,
     module="pydantic.main",
 )
-__version__ = "0.98.0"
+__version__ = "0.95.0"
 __all__ = [
     "Agent",
     "Crew",

src/crewai/agents/agent_builder/utilities/base_token_process.py

@@ -2,26 +2,26 @@ from crewai.types.usage_metrics import UsageMetrics
 
 
 class TokenProcess:
-    def __init__(self) -> None:
+    def __init__(self):
         self.total_tokens: int = 0
         self.prompt_tokens: int = 0
         self.cached_prompt_tokens: int = 0
         self.completion_tokens: int = 0
         self.successful_requests: int = 0
 
-    def sum_prompt_tokens(self, tokens: int) -> None:
-        self.prompt_tokens += tokens
-        self.total_tokens += tokens
+    def sum_prompt_tokens(self, tokens: int):
+        self.prompt_tokens = self.prompt_tokens + tokens
+        self.total_tokens = self.total_tokens + tokens
 
-    def sum_completion_tokens(self, tokens: int) -> None:
-        self.completion_tokens += tokens
-        self.total_tokens += tokens
+    def sum_completion_tokens(self, tokens: int):
+        self.completion_tokens = self.completion_tokens + tokens
+        self.total_tokens = self.total_tokens + tokens
 
-    def sum_cached_prompt_tokens(self, tokens: int) -> None:
-        self.cached_prompt_tokens += tokens
+    def sum_cached_prompt_tokens(self, tokens: int):
+        self.cached_prompt_tokens = self.cached_prompt_tokens + tokens
 
-    def sum_successful_requests(self, requests: int) -> None:
-        self.successful_requests += requests
+    def sum_successful_requests(self, requests: int):
+        self.successful_requests = self.successful_requests + requests
 
     def get_summary(self) -> UsageMetrics:
         return UsageMetrics(

src/crewai/cli/templates/crew/pyproject.toml

@@ -5,7 +5,7 @@ description = "{{name}} using crewAI"
 authors = [{ name = "Your Name", email = "you@example.com" }]
 requires-python = ">=3.10,<3.13"
 dependencies = [
-    "crewai[tools]>=0.98.0,<1.0.0"
+    "crewai[tools]>=0.95.0,<1.0.0"
 ]
 
 [project.scripts]

src/crewai/cli/templates/flow/main.py

@@ -3,7 +3,7 @@ from random import randint
 
 from pydantic import BaseModel
 
-from crewai.flow import Flow, listen, start
+from crewai.flow.flow import Flow, listen, start
 
 from {{folder_name}}.crews.poem_crew.poem_crew import PoemCrew
 

src/crewai/cli/templates/flow/pyproject.toml

@@ -5,7 +5,7 @@ description = "{{name}} using crewAI"
 authors = [{ name = "Your Name", email = "you@example.com" }]
 requires-python = ">=3.10,<3.13"
 dependencies = [
-    "crewai[tools]>=0.98.0,<1.0.0",
+    "crewai[tools]>=0.95.0,<1.0.0",
 ]
 
 [project.scripts]

src/crewai/cli/templates/tool/pyproject.toml

@@ -5,7 +5,7 @@ description = "Power up your crews with {{folder_name}}"
 readme = "README.md"
 requires-python = ">=3.10,<3.13"
 dependencies = [
-    "crewai[tools]>=0.98.0"
+    "crewai[tools]>=0.95.0"
 ]
 
 [tool.crewai]

src/crewai/flow/__init__.py

@@ -1,5 +1,3 @@
-from crewai.flow.flow import Flow, start, listen, or_, and_, router
-from crewai.flow.persistence import persist
-
-__all__ = ["Flow", "start", "listen", "or_", "and_", "router", "persist"]
+from crewai.flow.flow import Flow
 
+__all__ = ["Flow"]

src/crewai/flow/flow.py

@@ -1,6 +1,6 @@
 import asyncio
 import inspect
-import logging
+import uuid
 from typing import (
     Any,
     Callable,
@@ -13,6 +13,7 @@ from typing import (
     TypeVar,
     Union,
     cast,
+    overload,
 )
 from uuid import uuid4
 
@@ -26,68 +27,54 @@ from crewai.flow.flow_events import (
     MethodExecutionStartedEvent,
 )
 from crewai.flow.flow_visualizer import plot_flow
+from crewai.flow.persistence import FlowPersistence
 from crewai.flow.persistence.base import FlowPersistence
 from crewai.flow.utils import get_possible_return_constants
 from crewai.telemetry import Telemetry
-from crewai.utilities.printer import Printer
-
-logger = logging.getLogger(__name__)
 
 
 class FlowState(BaseModel):
     """Base model for all flow states, ensuring each state has a unique ID."""
-
-    id: str = Field(
-        default_factory=lambda: str(uuid4()),
-        description="Unique identifier for the flow state",
-    )
-
+    id: str = Field(default_factory=lambda: str(uuid4()), description="Unique identifier for the flow state")
 
 # Type variables with explicit bounds
-T = TypeVar(
-    "T", bound=Union[Dict[str, Any], BaseModel]
-)  # Generic flow state type parameter
-StateT = TypeVar(
-    "StateT", bound=Union[Dict[str, Any], BaseModel]
-)  # State validation type parameter
-
+T = TypeVar("T", bound=Union[Dict[str, Any], BaseModel])  # Generic flow state type parameter
+StateT = TypeVar("StateT", bound=Union[Dict[str, Any], BaseModel])  # State validation type parameter
 
 def ensure_state_type(state: Any, expected_type: Type[StateT]) -> StateT:
     """Ensure state matches expected type with proper validation.
-
+    
     Args:
         state: State instance to validate
         expected_type: Expected type for the state
-
+        
     Returns:
         Validated state instance
-
+        
     Raises:
         TypeError: If state doesn't match expected type
         ValueError: If state validation fails
     """
     """Ensure state matches expected type with proper validation.
-
+    
     Args:
         state: State instance to validate
         expected_type: Expected type for the state
-
+        
     Returns:
         Validated state instance
-
+        
     Raises:
         TypeError: If state doesn't match expected type
         ValueError: If state validation fails
     """
-    if expected_type is dict:
+    if expected_type == dict:
         if not isinstance(state, dict):
             raise TypeError(f"Expected dict, got {type(state).__name__}")
         return cast(StateT, state)
     if isinstance(expected_type, type) and issubclass(expected_type, BaseModel):
         if not isinstance(state, expected_type):
-            raise TypeError(
-                f"Expected {expected_type.__name__}, got {type(state).__name__}"
-            )
+            raise TypeError(f"Expected {expected_type.__name__}, got {type(state).__name__}")
         return cast(StateT, state)
     raise TypeError(f"Invalid expected_type: {expected_type}")
 
@@ -133,7 +120,6 @@ def start(condition: Optional[Union[str, dict, Callable]] = None) -> Callable:
     >>> def complex_start(self):
     ...     pass
     """
-
     def decorator(func):
         func.__is_start_method__ = True
         if condition is not None:
@@ -158,7 +144,6 @@ def start(condition: Optional[Union[str, dict, Callable]] = None) -> Callable:
 
     return decorator
 
-
 def listen(condition: Union[str, dict, Callable]) -> Callable:
     """
     Creates a listener that executes when specified conditions are met.
@@ -195,7 +180,6 @@ def listen(condition: Union[str, dict, Callable]) -> Callable:
     >>> def handle_completion(self):
     ...     pass
     """
-
     def decorator(func):
         if isinstance(condition, str):
             func.__trigger_methods__ = [condition]
@@ -260,7 +244,6 @@ def router(condition: Union[str, dict, Callable]) -> Callable:
     ...         return CONTINUE
     ...     return STOP
     """
-
     def decorator(func):
         func.__is_router__ = True
         if isinstance(condition, str):
@@ -284,7 +267,6 @@ def router(condition: Union[str, dict, Callable]) -> Callable:
 
     return decorator
 
-
 def or_(*conditions: Union[str, dict, Callable]) -> dict:
     """
     Combines multiple conditions with OR logic for flow control.
@@ -388,27 +370,22 @@ class FlowMeta(type):
 
         for attr_name, attr_value in dct.items():
             # Check for any flow-related attributes
-            if (
-                hasattr(attr_value, "__is_flow_method__")
-                or hasattr(attr_value, "__is_start_method__")
-                or hasattr(attr_value, "__trigger_methods__")
-                or hasattr(attr_value, "__is_router__")
-            ):
-
+            if (hasattr(attr_value, "__is_flow_method__") or
+                hasattr(attr_value, "__is_start_method__") or
+                hasattr(attr_value, "__trigger_methods__") or
+                hasattr(attr_value, "__is_router__")):
+                
                 # Register start methods
                 if hasattr(attr_value, "__is_start_method__"):
                     start_methods.append(attr_name)
-
+                
                 # Register listeners and routers
                 if hasattr(attr_value, "__trigger_methods__"):
                     methods = attr_value.__trigger_methods__
                     condition_type = getattr(attr_value, "__condition_type__", "OR")
                     listeners[attr_name] = (condition_type, methods)
-
-                    if (
-                        hasattr(attr_value, "__is_router__")
-                        and attr_value.__is_router__
-                    ):
+                    
+                    if hasattr(attr_value, "__is_router__") and attr_value.__is_router__:
                         routers.add(attr_name)
                         possible_returns = get_possible_return_constants(attr_value)
                         if possible_returns:
@@ -424,11 +401,9 @@ class FlowMeta(type):
 
 class Flow(Generic[T], metaclass=FlowMeta):
     """Base class for all flows.
-
+    
     Type parameter T must be either Dict[str, Any] or a subclass of BaseModel."""
-
     _telemetry = Telemetry()
-    _printer = Printer()
 
     _start_methods: List[str] = []
     _listeners: Dict[str, tuple[str, List[str]]] = {}
@@ -447,12 +422,14 @@ class Flow(Generic[T], metaclass=FlowMeta):
     def __init__(
         self,
         persistence: Optional[FlowPersistence] = None,
+        restore_uuid: Optional[str] = None,
         **kwargs: Any,
     ) -> None:
         """Initialize a new Flow instance.
-
+        
         Args:
             persistence: Optional persistence backend for storing flow states
+            restore_uuid: Optional UUID to restore state from persistence
             **kwargs: Additional state values to initialize or override
         """
         # Initialize basic instance attributes
@@ -461,13 +438,54 @@ class Flow(Generic[T], metaclass=FlowMeta):
         self._pending_and_listeners: Dict[str, Set[str]] = {}
         self._method_outputs: List[Any] = []  # List to store all method outputs
         self._persistence: Optional[FlowPersistence] = persistence
-
-        # Initialize state with initial values
-        self._state = self._create_initial_state()
-
-        # Apply any additional kwargs
-        if kwargs:
-            self._initialize_state(kwargs)
+        
+        # Validate state model before initialization
+        if isinstance(self.initial_state, type):
+            if issubclass(self.initial_state, BaseModel) and not issubclass(self.initial_state, FlowState):
+                # Check if model has id field
+                model_fields = getattr(self.initial_state, "model_fields", None)
+                if not model_fields or "id" not in model_fields:
+                    raise ValueError("Flow state model must have an 'id' field")
+        
+        # Handle persistence and potential ID conflicts
+        stored_state = None
+        if self._persistence is not None:
+            if restore_uuid and kwargs and "id" in kwargs and restore_uuid != kwargs["id"]:
+                raise ValueError(
+                    f"Conflicting IDs provided: restore_uuid='{restore_uuid}' "
+                    f"vs kwargs['id']='{kwargs['id']}'. Use only one ID for restoration."
+                )
+            
+            # Attempt to load state, prioritizing restore_uuid
+            if restore_uuid:
+                stored_state = self._persistence.load_state(restore_uuid)
+                if not stored_state:
+                    raise ValueError(f"No state found for restore_uuid='{restore_uuid}'")
+            elif kwargs and "id" in kwargs:
+                stored_state = self._persistence.load_state(kwargs["id"])
+                if not stored_state:
+                    # For kwargs["id"], we allow creating new state if not found
+                    self._state = self._create_initial_state()
+                    if kwargs:
+                        self._initialize_state(kwargs)
+                    return
+        
+        # Initialize state based on persistence and kwargs
+        if stored_state:
+            # Create initial state and restore from persistence
+            self._state = self._create_initial_state()
+            self._restore_state(stored_state)
+            # Apply any additional kwargs to override specific fields
+            if kwargs:
+                filtered_kwargs = {k: v for k, v in kwargs.items() if k != "id"}
+                if filtered_kwargs:
+                    self._initialize_state(filtered_kwargs)
+        else:
+            # No stored state, create new state with initial values
+            self._state = self._create_initial_state()
+            # Apply any additional kwargs
+            if kwargs:
+                self._initialize_state(kwargs)
 
         self._telemetry.flow_creation_span(self.__class__.__name__)
 
@@ -476,23 +494,23 @@ class Flow(Generic[T], metaclass=FlowMeta):
             if not method_name.startswith("_"):
                 method = getattr(self, method_name)
                 # Check for any flow-related attributes
-                if (
-                    hasattr(method, "__is_flow_method__")
-                    or hasattr(method, "__is_start_method__")
-                    or hasattr(method, "__trigger_methods__")
-                    or hasattr(method, "__is_router__")
-                ):
+                if (hasattr(method, "__is_flow_method__") or
+                    hasattr(method, "__is_start_method__") or
+                    hasattr(method, "__trigger_methods__") or
+                    hasattr(method, "__is_router__")):
                     # Ensure method is bound to this instance
                     if not hasattr(method, "__self__"):
                         method = method.__get__(self, self.__class__)
                     self._methods[method_name] = method
 
+
+    
     def _create_initial_state(self) -> T:
         """Create and initialize flow state with UUID and default values.
-
+        
         Returns:
             New state instance with UUID and default values initialized
-
+            
         Raises:
             ValueError: If structured state model lacks 'id' field
             TypeError: If state is neither BaseModel nor dictionary
@@ -504,25 +522,24 @@ class Flow(Generic[T], metaclass=FlowMeta):
                 if issubclass(state_type, FlowState):
                     # Create instance without id, then set it
                     instance = state_type()
-                    if not hasattr(instance, "id"):
-                        setattr(instance, "id", str(uuid4()))
+                    if not hasattr(instance, 'id'):
+                        setattr(instance, 'id', str(uuid4()))
                     return cast(T, instance)
                 elif issubclass(state_type, BaseModel):
                     # Create a new type that includes the ID field
                     class StateWithId(state_type, FlowState):  # type: ignore
                         pass
-
                     instance = StateWithId()
-                    if not hasattr(instance, "id"):
-                        setattr(instance, "id", str(uuid4()))
+                    if not hasattr(instance, 'id'):
+                        setattr(instance, 'id', str(uuid4()))
                     return cast(T, instance)
-                elif state_type is dict:
-                    return cast(T, {"id": str(uuid4())})
-
+                elif state_type == dict:
+                    return cast(T, {"id": str(uuid4())})  # Minimal dict state
+        
         # Handle case where no initial state is provided
         if self.initial_state is None:
             return cast(T, {"id": str(uuid4())})
-
+        
         # Handle case where initial_state is a type (class)
         if isinstance(self.initial_state, type):
             if issubclass(self.initial_state, FlowState):
@@ -533,22 +550,22 @@ class Flow(Generic[T], metaclass=FlowMeta):
                 if not model_fields or "id" not in model_fields:
                     raise ValueError("Flow state model must have an 'id' field")
                 return cast(T, self.initial_state())  # Uses model defaults
-            elif self.initial_state is dict:
+            elif self.initial_state == dict:
                 return cast(T, {"id": str(uuid4())})
-
+        
         # Handle dictionary instance case
         if isinstance(self.initial_state, dict):
             new_state = dict(self.initial_state)  # Copy to avoid mutations
             if "id" not in new_state:
                 new_state["id"] = str(uuid4())
             return cast(T, new_state)
-
+        
         # Handle BaseModel instance case
         if isinstance(self.initial_state, BaseModel):
             model = cast(BaseModel, self.initial_state)
             if not hasattr(model, "id"):
                 raise ValueError("Flow state model must have an 'id' field")
-
+            
             # Create new instance with same values to avoid mutations
             if hasattr(model, "model_dump"):
                 # Pydantic v2
@@ -559,12 +576,60 @@ class Flow(Generic[T], metaclass=FlowMeta):
             else:
                 # Fallback for other BaseModel implementations
                 state_dict = {
-                    k: v for k, v in model.__dict__.items() if not k.startswith("_")
+                    k: v for k, v in model.__dict__.items()
+                    if not k.startswith("_")
                 }
-
+            
             # Create new instance of the same class
             model_class = type(model)
             return cast(T, model_class(**state_dict))
+            
+        raise TypeError(
+            f"Initial state must be dict or BaseModel, got {type(self.initial_state)}"
+        )
+        # Handle case where initial_state is None but we have a type parameter
+        if self.initial_state is None and hasattr(self, "_initial_state_T"):
+            state_type = getattr(self, "_initial_state_T")
+            if isinstance(state_type, type):
+                if issubclass(state_type, FlowState):
+                    return cast(T, state_type())
+                elif issubclass(state_type, BaseModel):
+                    # Create a new type that includes the ID field
+                    class StateWithId(state_type, FlowState):  # type: ignore
+                        pass
+                    return cast(T, StateWithId())
+                elif state_type == dict:
+                    return cast(T, {"id": str(uuid4())})
+
+        # Handle case where no initial state is provided
+        if self.initial_state is None:
+            return cast(T, {"id": str(uuid4())})
+
+        # Handle case where initial_state is a type (class)
+        if isinstance(self.initial_state, type):
+            if issubclass(self.initial_state, FlowState):
+                return cast(T, self.initial_state())
+            elif issubclass(self.initial_state, BaseModel):
+                # Validate that the model has an id field
+                model_fields = getattr(self.initial_state, "model_fields", None)
+                if not model_fields or "id" not in model_fields:
+                    raise ValueError("Flow state model must have an 'id' field")
+                return cast(T, self.initial_state())
+            elif self.initial_state == dict:
+                return cast(T, {"id": str(uuid4())})
+
+        # Handle dictionary instance case
+        if isinstance(self.initial_state, dict):
+            if "id" not in self.initial_state:
+                self.initial_state["id"] = str(uuid4())
+            return cast(T, dict(self.initial_state))  # Create new dict to avoid mutations
+
+        # Handle BaseModel instance case
+        if isinstance(self.initial_state, BaseModel):
+            if not hasattr(self.initial_state, "id"):
+                raise ValueError("Flow state model must have an 'id' field")
+            return cast(T, self.initial_state)
+            
         raise TypeError(
             f"Initial state must be dict or BaseModel, got {type(self.initial_state)}"
         )
@@ -578,45 +643,12 @@ class Flow(Generic[T], metaclass=FlowMeta):
         """Returns the list of all outputs from executed methods."""
         return self._method_outputs
 
-    @property
-    def flow_id(self) -> str:
-        """Returns the unique identifier of this flow instance.
-
-        This property provides a consistent way to access the flow's unique identifier
-        regardless of the underlying state implementation (dict or BaseModel).
-
-        Returns:
-            str: The flow's unique identifier, or an empty string if not found
-
-        Note:
-            This property safely handles both dictionary and BaseModel state types,
-            returning an empty string if the ID cannot be retrieved rather than raising
-            an exception.
-
-        Example:
-            ```python
-            flow = MyFlow()
-            print(f"Current flow ID: {flow.flow_id}")  # Safely get flow ID
-            ```
-        """
-        try:
-            if not hasattr(self, '_state'):
-                return ""
-
-            if isinstance(self._state, dict):
-                return str(self._state.get("id", ""))
-            elif isinstance(self._state, BaseModel):
-                return str(getattr(self._state, "id", ""))
-            return ""
-        except (AttributeError, TypeError):
-            return ""  # Safely handle any unexpected attribute access issues
-
     def _initialize_state(self, inputs: Dict[str, Any]) -> None:
         """Initialize or update flow state with new inputs.
-
+        
         Args:
             inputs: Dictionary of state values to set/update
-
+            
         Raises:
             ValueError: If validation fails for structured state
             TypeError: If state is neither BaseModel nor dictionary
@@ -643,12 +675,13 @@ class Flow(Generic[T], metaclass=FlowMeta):
                     current_state = model.dict()
                 else:
                     current_state = {
-                        k: v for k, v in model.__dict__.items() if not k.startswith("_")
+                        k: v for k, v in model.__dict__.items()
+                        if not k.startswith("_")
                     }
-
+                
                 # Create new state with preserved fields and updates
                 new_state = {**current_state, **inputs}
-
+                
                 # Create new instance with merged state
                 model_class = type(model)
                 if hasattr(model_class, "model_validate"):
@@ -664,13 +697,13 @@ class Flow(Generic[T], metaclass=FlowMeta):
                 raise ValueError(f"Invalid inputs for structured state: {e}") from e
         else:
             raise TypeError("State must be a BaseModel instance or a dictionary.")
-
+            
     def _restore_state(self, stored_state: Dict[str, Any]) -> None:
         """Restore flow state from persistence.
-
+        
         Args:
             stored_state: Previously stored state to restore
-
+            
         Raises:
             ValueError: If validation fails for structured state
             TypeError: If state is neither BaseModel nor dictionary
@@ -679,7 +712,7 @@ class Flow(Generic[T], metaclass=FlowMeta):
         stored_id = stored_state.get("id")
         if not stored_id:
             raise ValueError("Stored state must have an 'id' field")
-
+        
         if isinstance(self._state, dict):
             # For dict states, update all fields from stored state
             self._state.clear()
@@ -697,39 +730,11 @@ class Flow(Generic[T], metaclass=FlowMeta):
                 # Fallback for other BaseModel implementations
                 self._state = cast(T, type(model)(**stored_state))
         else:
-            raise TypeError(f"State must be dict or BaseModel, got {type(self._state)}")
+            raise TypeError(
+                f"State must be dict or BaseModel, got {type(self._state)}"
+            )
 
     def kickoff(self, inputs: Optional[Dict[str, Any]] = None) -> Any:
-        """Start the flow execution.
-
-        Args:
-            inputs: Optional dictionary containing input values and potentially a state ID to restore
-        """
-        # Handle state restoration if ID is provided in inputs
-        if inputs and 'id' in inputs and self._persistence is not None:
-            restore_uuid = inputs['id']
-            stored_state = self._persistence.load_state(restore_uuid)
-
-            # Override the id in the state if it exists in inputs
-            if 'id' in inputs:
-                if isinstance(self._state, dict):
-                    self._state['id'] = inputs['id']
-                elif isinstance(self._state, BaseModel):
-                    setattr(self._state, 'id', inputs['id'])
-
-            if stored_state:
-                self._log_flow_event(f"Loading flow state from memory for UUID: {restore_uuid}", color="yellow")
-                # Restore the state
-                self._restore_state(stored_state)
-            else:
-                self._log_flow_event(f"No flow state found for UUID: {restore_uuid}", color="red")
-
-            # Apply any additional inputs after restoration
-            filtered_inputs = {k: v for k, v in inputs.items() if k != 'id'}
-            if filtered_inputs:
-                self._initialize_state(filtered_inputs)
-
-        # Start flow execution
         self.event_emitter.send(
             self,
             event=FlowStartedEvent(
@@ -737,11 +742,9 @@ class Flow(Generic[T], metaclass=FlowMeta):
                 flow_name=self.__class__.__name__,
             ),
         )
-        self._log_flow_event(f"Flow started with ID: {self.flow_id}", color="bold_magenta")
 
-        if inputs is not None and 'id' not in inputs:
+        if inputs is not None:
             self._initialize_state(inputs)
-
         return asyncio.run(self.kickoff_async())
 
     async def kickoff_async(self, inputs: Optional[Dict[str, Any]] = None) -> Any:
@@ -984,30 +987,6 @@ class Flow(Generic[T], metaclass=FlowMeta):
 
             traceback.print_exc()
 
-    def _log_flow_event(self, message: str, color: str = "yellow", level: str = "info") -> None:
-        """Centralized logging method for flow events.
-
-        This method provides a consistent interface for logging flow-related events,
-        combining both console output with colors and proper logging levels.
-
-        Args:
-            message: The message to log
-            color: Color to use for console output (default: yellow)
-                  Available colors: purple, red, bold_green, bold_purple,
-                  bold_blue, yellow, yellow
-            level: Log level to use (default: info)
-                  Supported levels: info, warning
-
-        Note:
-            This method uses the Printer utility for colored console output
-            and the standard logging module for log level support.
-        """
-        self._printer.print(message, color=color)
-        if level == "info":
-            logger.info(message)
-        elif level == "warning":
-            logger.warning(message)
-
     def plot(self, filename: str = "crewai_flow") -> None:
         self._telemetry.flow_plotting_span(
             self.__class__.__name__, list(self._methods.keys())

src/crewai/flow/persistence/decorators.py

@@ -5,14 +5,14 @@ Example:
     ```python
     from crewai.flow.flow import Flow, start
     from crewai.flow.persistence import persist, SQLiteFlowPersistence
-
+    
     class MyFlow(Flow):
         @start()
         @persist(SQLiteFlowPersistence())
         def sync_method(self):
             # Synchronous method implementation
             pass
-
+            
         @start()
         @persist(SQLiteFlowPersistence())
         async def async_method(self):
@@ -23,117 +23,48 @@ Example:
 
 import asyncio
 import functools
+import inspect
 import logging
 from typing import (
     Any,
     Callable,
+    Dict,
     Optional,
     Type,
     TypeVar,
     Union,
     cast,
+    get_type_hints,
 )
 
 from pydantic import BaseModel
 
 from crewai.flow.persistence.base import FlowPersistence
 from crewai.flow.persistence.sqlite import SQLiteFlowPersistence
-from crewai.utilities.printer import Printer
 
 logger = logging.getLogger(__name__)
 T = TypeVar("T")
 
-# Constants for log messages
-LOG_MESSAGES = {
-    "save_state": "Saving flow state to memory for ID: {}",
-    "save_error": "Failed to persist state for method {}: {}",
-    "state_missing": "Flow instance has no state",
-    "id_missing": "Flow state must have an 'id' field for persistence"
-}
-
-
-class PersistenceDecorator:
-    """Class to handle flow state persistence with consistent logging."""
-
-    _printer = Printer()  # Class-level printer instance
-
-    @classmethod
-    def persist_state(cls, flow_instance: Any, method_name: str, persistence_instance: FlowPersistence) -> None:
-        """Persist flow state with proper error handling and logging.
-
-        This method handles the persistence of flow state data, including proper
-        error handling and colored console output for status updates.
-
-        Args:
-            flow_instance: The flow instance whose state to persist
-            method_name: Name of the method that triggered persistence
-            persistence_instance: The persistence backend to use
-
-        Raises:
-            ValueError: If flow has no state or state lacks an ID
-            RuntimeError: If state persistence fails
-            AttributeError: If flow instance lacks required state attributes
-        """
-        try:
-            state = getattr(flow_instance, 'state', None)
-            if state is None:
-                raise ValueError("Flow instance has no state")
-
-            flow_uuid: Optional[str] = None
-            if isinstance(state, dict):
-                flow_uuid = state.get('id')
-            elif isinstance(state, BaseModel):
-                flow_uuid = getattr(state, 'id', None)
-
-            if not flow_uuid:
-                raise ValueError("Flow state must have an 'id' field for persistence")
-
-            # Log state saving with consistent message
-            cls._printer.print(LOG_MESSAGES["save_state"].format(flow_uuid), color="cyan")
-            logger.info(LOG_MESSAGES["save_state"].format(flow_uuid))
-
-            try:
-                persistence_instance.save_state(
-                    flow_uuid=flow_uuid,
-                    method_name=method_name,
-                    state_data=state,
-                )
-            except Exception as e:
-                error_msg = LOG_MESSAGES["save_error"].format(method_name, str(e))
-                cls._printer.print(error_msg, color="red")
-                logger.error(error_msg)
-                raise RuntimeError(f"State persistence failed: {str(e)}") from e
-        except AttributeError:
-            error_msg = LOG_MESSAGES["state_missing"]
-            cls._printer.print(error_msg, color="red")
-            logger.error(error_msg)
-            raise ValueError(error_msg)
-        except (TypeError, ValueError) as e:
-            error_msg = LOG_MESSAGES["id_missing"]
-            cls._printer.print(error_msg, color="red")
-            logger.error(error_msg)
-            raise ValueError(error_msg) from e
-
 
 def persist(persistence: Optional[FlowPersistence] = None):
     """Decorator to persist flow state.
-
+    
     This decorator can be applied at either the class level or method level.
     When applied at the class level, it automatically persists all flow method
     states. When applied at the method level, it persists only that method's
     state.
-
+    
     Args:
         persistence: Optional FlowPersistence implementation to use.
                     If not provided, uses SQLiteFlowPersistence.
-
+    
     Returns:
         A decorator that can be applied to either a class or method
-
+    
     Raises:
         ValueError: If the flow state doesn't have an 'id' field
         RuntimeError: If state persistence fails
-
+        
     Example:
         @persist  # Class-level persistence with default SQLite
         class MyFlow(Flow[MyState]):
@@ -141,85 +72,81 @@ def persist(persistence: Optional[FlowPersistence] = None):
             def begin(self):
                 pass
     """
-
+    def _persist_state(flow_instance: Any, method_name: str, persistence_instance: FlowPersistence) -> None:
+        """Helper to persist state with error handling."""
+        try:
+            # Get flow UUID from state
+            state = getattr(flow_instance, 'state', None)
+            if state is None:
+                raise ValueError("Flow instance has no state")
+                
+            flow_uuid: Optional[str] = None
+            if isinstance(state, dict):
+                flow_uuid = state.get('id')
+            elif isinstance(state, BaseModel):
+                flow_uuid = getattr(state, 'id', None)
+                
+            if not flow_uuid:
+                raise ValueError(
+                    "Flow state must have an 'id' field for persistence"
+                )
+                
+            # Persist the state
+            persistence_instance.save_state(
+                flow_uuid=flow_uuid,
+                method_name=method_name,
+                state_data=state,
+            )
+        except Exception as e:
+            logger.error(
+                f"Failed to persist state for method {method_name}: {str(e)}"
+            )
+            raise RuntimeError(f"State persistence failed: {str(e)}") from e
+    
     def decorator(target: Union[Type, Callable[..., T]]) -> Union[Type, Callable[..., T]]:
         """Decorator that handles both class and method decoration."""
         actual_persistence = persistence or SQLiteFlowPersistence()
-
+        
         if isinstance(target, type):
             # Class decoration
-            original_init = getattr(target, "__init__")
-
-            @functools.wraps(original_init)
-            def new_init(self: Any, *args: Any, **kwargs: Any) -> None:
-                if 'persistence' not in kwargs:
-                    kwargs['persistence'] = actual_persistence
-                original_init(self, *args, **kwargs)
-
-            setattr(target, "__init__", new_init)
-
-            # Store original methods to preserve their decorators
-            original_methods = {}
-
+            class_methods = {}
             for name, method in target.__dict__.items():
-                if callable(method) and (
-                    hasattr(method, "__is_start_method__") or
-                    hasattr(method, "__trigger_methods__") or
-                    hasattr(method, "__condition_type__") or
-                    hasattr(method, "__is_flow_method__") or
-                    hasattr(method, "__is_router__")
-                ):
-                    original_methods[name] = method
-
-            # Create wrapped versions of the methods that include persistence
-            for name, method in original_methods.items():
-                if asyncio.iscoroutinefunction(method):
-                    # Create a closure to capture the current name and method
-                    def create_async_wrapper(method_name: str, original_method: Callable):
-                        @functools.wraps(original_method)
-                        async def method_wrapper(self: Any, *args: Any, **kwargs: Any) -> Any:
-                            result = await original_method(self, *args, **kwargs)
-                            PersistenceDecorator.persist_state(self, method_name, actual_persistence)
+                if callable(method) and hasattr(method, "__is_flow_method__"):
+                    # Wrap each flow method with persistence
+                    if asyncio.iscoroutinefunction(method):
+                        @functools.wraps(method)
+                        async def class_async_wrapper(self: Any, *args: Any, **kwargs: Any) -> Any:
+                            method_coro = method(self, *args, **kwargs)
+                            if asyncio.iscoroutine(method_coro):
+                                result = await method_coro
+                            else:
+                                result = method_coro
+                            _persist_state(self, method.__name__, actual_persistence)
                             return result
-                        return method_wrapper
-
-                    wrapped = create_async_wrapper(name, method)
-
-                    # Preserve all original decorators and attributes
+                        class_methods[name] = class_async_wrapper
+                    else:
+                        @functools.wraps(method)
+                        def class_sync_wrapper(self: Any, *args: Any, **kwargs: Any) -> Any:
+                            result = method(self, *args, **kwargs)
+                            _persist_state(self, method.__name__, actual_persistence)
+                            return result
+                        class_methods[name] = class_sync_wrapper
+                    
+                    # Preserve flow-specific attributes
                     for attr in ["__is_start_method__", "__trigger_methods__", "__condition_type__", "__is_router__"]:
                         if hasattr(method, attr):
-                            setattr(wrapped, attr, getattr(method, attr))
-                    setattr(wrapped, "__is_flow_method__", True)
-
-                    # Update the class with the wrapped method
-                    setattr(target, name, wrapped)
-                else:
-                    # Create a closure to capture the current name and method
-                    def create_sync_wrapper(method_name: str, original_method: Callable):
-                        @functools.wraps(original_method)
-                        def method_wrapper(self: Any, *args: Any, **kwargs: Any) -> Any:
-                            result = original_method(self, *args, **kwargs)
-                            PersistenceDecorator.persist_state(self, method_name, actual_persistence)
-                            return result
-                        return method_wrapper
-
-                    wrapped = create_sync_wrapper(name, method)
-
-                    # Preserve all original decorators and attributes
-                    for attr in ["__is_start_method__", "__trigger_methods__", "__condition_type__", "__is_router__"]:
-                        if hasattr(method, attr):
-                            setattr(wrapped, attr, getattr(method, attr))
-                    setattr(wrapped, "__is_flow_method__", True)
-
-                    # Update the class with the wrapped method
-                    setattr(target, name, wrapped)
-
+                            setattr(class_methods[name], attr, getattr(method, attr))
+                    setattr(class_methods[name], "__is_flow_method__", True)
+            
+            # Update class with wrapped methods
+            for name, method in class_methods.items():
+                setattr(target, name, method)
             return target
         else:
             # Method decoration
             method = target
             setattr(method, "__is_flow_method__", True)
-
+            
             if asyncio.iscoroutinefunction(method):
                 @functools.wraps(method)
                 async def method_async_wrapper(flow_instance: Any, *args: Any, **kwargs: Any) -> T:
@@ -228,9 +155,8 @@ def persist(persistence: Optional[FlowPersistence] = None):
                         result = await method_coro
                     else:
                         result = method_coro
-                    PersistenceDecorator.persist_state(flow_instance, method.__name__, actual_persistence)
+                    _persist_state(flow_instance, method.__name__, actual_persistence)
                     return result
-
                 for attr in ["__is_start_method__", "__trigger_methods__", "__condition_type__", "__is_router__"]:
                     if hasattr(method, attr):
                         setattr(method_async_wrapper, attr, getattr(method, attr))
@@ -240,13 +166,12 @@ def persist(persistence: Optional[FlowPersistence] = None):
                 @functools.wraps(method)
                 def method_sync_wrapper(flow_instance: Any, *args: Any, **kwargs: Any) -> T:
                     result = method(flow_instance, *args, **kwargs)
-                    PersistenceDecorator.persist_state(flow_instance, method.__name__, actual_persistence)
+                    _persist_state(flow_instance, method.__name__, actual_persistence)
                     return result
-
                 for attr in ["__is_start_method__", "__trigger_methods__", "__condition_type__", "__is_router__"]:
                     if hasattr(method, attr):
                         setattr(method_sync_wrapper, attr, getattr(method, attr))
                 setattr(method_sync_wrapper, "__is_flow_method__", True)
                 return cast(Callable[..., T], method_sync_wrapper)
-
+            
     return decorator

src/crewai/flow/persistence/sqlite.py

@@ -3,9 +3,10 @@ SQLite-based implementation of flow state persistence.
 """
 
 import json
+import os
 import sqlite3
+import tempfile
 from datetime import datetime
-from pathlib import Path
 from typing import Any, Dict, Optional, Union
 
 from pydantic import BaseModel
@@ -15,34 +16,34 @@ from crewai.flow.persistence.base import FlowPersistence
 
 class SQLiteFlowPersistence(FlowPersistence):
     """SQLite-based implementation of flow state persistence.
-
+    
     This class provides a simple, file-based persistence implementation using SQLite.
     It's suitable for development and testing, or for production use cases with
     moderate performance requirements.
     """
-
+    
     db_path: str  # Type annotation for instance variable
-
+    
     def __init__(self, db_path: Optional[str] = None):
         """Initialize SQLite persistence.
-
+        
         Args:
             db_path: Path to the SQLite database file. If not provided, uses
                     db_storage_path() from utilities.paths.
-
+                    
         Raises:
             ValueError: If db_path is invalid
         """
         from crewai.utilities.paths import db_storage_path
         # Get path from argument or default location
-        path = db_path or str(Path(db_storage_path()) / "flow_states.db")
-
+        path = db_path or db_storage_path()
+        
         if not path:
             raise ValueError("Database path must be provided")
-
+            
         self.db_path = path  # Now mypy knows this is str
         self.init_db()
-
+    
     def init_db(self) -> None:
         """Create the necessary tables if they don't exist."""
         with sqlite3.connect(self.db_path) as conn:
@@ -57,10 +58,10 @@ class SQLiteFlowPersistence(FlowPersistence):
             """)
             # Add index for faster UUID lookups
             conn.execute("""
-            CREATE INDEX IF NOT EXISTS idx_flow_states_uuid
+            CREATE INDEX IF NOT EXISTS idx_flow_states_uuid 
             ON flow_states(flow_uuid)
             """)
-
+    
     def save_state(
         self,
         flow_uuid: str,
@@ -68,7 +69,7 @@ class SQLiteFlowPersistence(FlowPersistence):
         state_data: Union[Dict[str, Any], BaseModel],
     ) -> None:
         """Save the current flow state to SQLite.
-
+        
         Args:
             flow_uuid: Unique identifier for the flow instance
             method_name: Name of the method that just completed
@@ -83,7 +84,7 @@ class SQLiteFlowPersistence(FlowPersistence):
             raise ValueError(
                 f"state_data must be either a Pydantic BaseModel or dict, got {type(state_data)}"
             )
-
+            
         with sqlite3.connect(self.db_path) as conn:
             conn.execute("""
             INSERT INTO flow_states (
@@ -98,13 +99,13 @@ class SQLiteFlowPersistence(FlowPersistence):
                 datetime.utcnow().isoformat(),
                 json.dumps(state_dict),
             ))
-
+    
     def load_state(self, flow_uuid: str) -> Optional[Dict[str, Any]]:
         """Load the most recent state for a given flow UUID.
-
+        
         Args:
             flow_uuid: Unique identifier for the flow instance
-
+            
         Returns:
             The most recent state as a dictionary, or None if no state exists
         """
@@ -117,7 +118,7 @@ class SQLiteFlowPersistence(FlowPersistence):
             LIMIT 1
             """, (flow_uuid,))
             row = cursor.fetchone()
-
+            
         if row:
             return json.loads(row[0])
         return None

src/crewai/memory/storage/kickoff_task_outputs_storage.py

@@ -23,7 +23,7 @@ class KickoffTaskOutputsSQLiteStorage:
     ) -> None:
         if db_path is None:
             # Get the parent directory of the default db path and create our db file there
-            db_path = str(Path(db_storage_path()) / "latest_kickoff_task_outputs.db")
+            db_path = str(Path(db_storage_path()).parent / "latest_kickoff_task_outputs.db")
         self.db_path = db_path
         self._printer: Printer = Printer()
         self._initialize_db()

src/crewai/memory/storage/ltm_sqlite_storage.py

@@ -17,7 +17,7 @@ class LTMSQLiteStorage:
     ) -> None:
         if db_path is None:
             # Get the parent directory of the default db path and create our db file there
-            db_path = str(Path(db_storage_path()) / "long_term_memory_storage.db")
+            db_path = str(Path(db_storage_path()).parent / "long_term_memory_storage.db")
         self.db_path = db_path
         self._printer: Printer = Printer()
         # Ensure parent directory exists

src/crewai/utilities/converter.py

@@ -241,13 +241,9 @@ def generate_model_description(model: Type[BaseModel]) -> str:
         origin = get_origin(field_type)
         args = get_args(field_type)
 
-        if origin is Union or (origin is None and len(args) > 0):
-            # Handle both Union and the new '|' syntax
+        if origin is Union and type(None) in args:
             non_none_args = [arg for arg in args if arg is not type(None)]
-            if len(non_none_args) == 1:
-                return f"Optional[{describe_field(non_none_args[0])}]"
-            else:
-                return f"Optional[Union[{', '.join(describe_field(arg) for arg in non_none_args)}]]"
+            return f"Optional[{describe_field(non_none_args[0])}]"
         elif origin is list:
             return f"List[{describe_field(args[0])}]"
         elif origin is dict:
@@ -256,10 +252,8 @@ def generate_model_description(model: Type[BaseModel]) -> str:
             return f"Dict[{key_type}, {value_type}]"
         elif isinstance(field_type, type) and issubclass(field_type, BaseModel):
             return generate_model_description(field_type)
-        elif hasattr(field_type, "__name__"):
-            return field_type.__name__
         else:
-            return str(field_type)
+            return field_type.__name__
 
     fields = model.__annotations__
     field_descriptions = [

src/crewai/utilities/embedding_configurator.py

@@ -14,7 +14,6 @@ class EmbeddingConfigurator:
             "vertexai": self._configure_vertexai,
             "google": self._configure_google,
             "cohere": self._configure_cohere,
-            "voyageai": self._configure_voyageai,
             "bedrock": self._configure_bedrock,
             "huggingface": self._configure_huggingface,
             "watson": self._configure_watson,
@@ -125,17 +124,6 @@ class EmbeddingConfigurator:
             api_key=config.get("api_key"),
         )
 
-    @staticmethod
-    def _configure_voyageai(config, model_name):
-        from chromadb.utils.embedding_functions.voyageai_embedding_function import (
-            VoyageAIEmbeddingFunction,
-        )
-
-        return VoyageAIEmbeddingFunction(
-            model_name=model_name,
-            api_key=config.get("api_key"),
-        )
-
     @staticmethod
     def _configure_bedrock(config, model_name):
         from chromadb.utils.embedding_functions.amazon_bedrock_embedding_function import (

src/crewai/utilities/llm_utils.py

@@ -24,12 +24,10 @@ def create_llm(
 
     # 1) If llm_value is already an LLM object, return it directly
     if isinstance(llm_value, LLM):
-        print("LLM value is already an LLM object")
         return llm_value
 
     # 2) If llm_value is a string (model name)
     if isinstance(llm_value, str):
-        print("LLM value is a string")
         try:
             created_llm = LLM(model=llm_value)
             return created_llm
@@ -39,12 +37,10 @@ def create_llm(
 
     # 3) If llm_value is None, parse environment variables or use default
     if llm_value is None:
-        print("LLM value is None")
         return _llm_via_environment_or_fallback()
 
     # 4) Otherwise, attempt to extract relevant attributes from an unknown object
     try:
-        print("LLM value is an unknown object")
         # Extract attributes with explicit types
         model = (
             getattr(llm_value, "model_name", None)

src/crewai/utilities/paths.py

@@ -7,7 +7,7 @@ import appdirs
 
 def db_storage_path() -> str:
     """Returns the path for SQLite database storage.
-
+    
     Returns:
         str: Full path to the SQLite database file
     """
@@ -16,7 +16,7 @@ def db_storage_path() -> str:
 
     data_dir = Path(appdirs.user_data_dir(app_name, app_author))
     data_dir.mkdir(parents=True, exist_ok=True)
-    return str(data_dir)
+    return str(data_dir / "crewai_flows.db")
 
 
 def get_project_directory_name():
@@ -28,4 +28,4 @@ def get_project_directory_name():
     else:
         cwd = Path.cwd()
         project_directory_name = cwd.name
-        return project_directory_name
+        return project_directory_name

src/crewai/utilities/printer.py

@@ -21,16 +21,6 @@ class Printer:
             self._print_yellow(content)
         elif color == "bold_yellow":
             self._print_bold_yellow(content)
-        elif color == "cyan":
-            self._print_cyan(content)
-        elif color == "bold_cyan":
-            self._print_bold_cyan(content)
-        elif color == "magenta":
-            self._print_magenta(content)
-        elif color == "bold_magenta":
-            self._print_bold_magenta(content)
-        elif color == "green":
-            self._print_green(content)
         else:
             print(content)
 
@@ -54,18 +44,3 @@ class Printer:
 
     def _print_bold_yellow(self, content):
         print("\033[1m\033[93m {}\033[00m".format(content))
-
-    def _print_cyan(self, content):
-        print("\033[96m {}\033[00m".format(content))
-
-    def _print_bold_cyan(self, content):
-        print("\033[1m\033[96m {}\033[00m".format(content))
-
-    def _print_magenta(self, content):
-        print("\033[35m {}\033[00m".format(content))
-
-    def _print_bold_magenta(self, content):
-        print("\033[1m\033[35m {}\033[00m".format(content))
-
-    def _print_green(self, content):
-        print("\033[32m {}\033[00m".format(content))

tests/agent_test.py

@@ -114,6 +114,35 @@ def test_custom_llm_temperature_preservation():
     assert agent.llm.temperature == 0.7
 
 
+@pytest.mark.vcr(filter_headers=["authorization"])
+def test_agent_execute_task():
+    from langchain_openai import ChatOpenAI
+
+    from crewai import Task
+
+    agent = Agent(
+        role="Math Tutor",
+        goal="Solve math problems accurately",
+        backstory="You are an experienced math tutor with a knack for explaining complex concepts simply.",
+        llm=ChatOpenAI(temperature=0.7, model="gpt-4o-mini"),
+    )
+
+    task = Task(
+        description="Calculate the area of a circle with radius 5 cm.",
+        expected_output="The calculated area of the circle in square centimeters.",
+        agent=agent,
+    )
+
+    result = agent.execute_task(task)
+
+    assert result is not None
+    assert (
+        result
+        == "The calculated area of the circle is approximately 78.5 square centimeters."
+    )
+    assert "square centimeters" in result.lower()
+
+
 @pytest.mark.vcr(filter_headers=["authorization"])
 def test_agent_execution():
     agent = Agent(

tests/cassettes/test_agent_execute_task.yaml

@@ -0,0 +1,121 @@
+interactions:
+- request:
+    body: '{"messages": [{"role": "system", "content": "You are Math Tutor. You are
+      an experienced math tutor with a knack for explaining complex concepts simply.\nYour
+      personal goal is: Solve math problems accurately\nTo give my best complete final
+      answer to the task use the exact following format:\n\nThought: I now can give
+      a great answer\nFinal Answer: Your final answer must be the great and the most
+      complete as possible, it must be outcome described.\n\nI MUST use these formats,
+      my job depends on it!"}, {"role": "user", "content": "\nCurrent Task: Calculate
+      the area of a circle with radius 5 cm.\n\nThis is the expect criteria for your
+      final answer: The calculated area of the circle in square centimeters.\nyou
+      MUST return the actual complete content as the final answer, not a summary.\n\nBegin!
+      This is VERY important to you, use the tools available and give your best Final
+      Answer, your job depends on it!\n\nThought:"}], "model": "gpt-4o-mini", "temperature":
+      0.7}'
+    headers:
+      accept:
+      - application/json
+      accept-encoding:
+      - gzip, deflate
+      connection:
+      - keep-alive
+      content-length:
+      - '969'
+      content-type:
+      - application/json
+      host:
+      - api.openai.com
+      user-agent:
+      - OpenAI/Python 1.47.0
+      x-stainless-arch:
+      - arm64
+      x-stainless-async:
+      - 'false'
+      x-stainless-lang:
+      - python
+      x-stainless-os:
+      - MacOS
+      x-stainless-package-version:
+      - 1.47.0
+      x-stainless-raw-response:
+      - 'true'
+      x-stainless-runtime:
+      - CPython
+      x-stainless-runtime-version:
+      - 3.11.7
+    method: POST
+    uri: https://api.openai.com/v1/chat/completions
+  response:
+    content: "{\n  \"id\": \"chatcmpl-AB7LEfa5gX4cncpI4avsK0CJG8pCb\",\n  \"object\":
+      \"chat.completion\",\n  \"created\": 1727213192,\n  \"model\": \"gpt-4o-mini-2024-07-18\",\n
+      \ \"choices\": [\n    {\n      \"index\": 0,\n      \"message\": {\n        \"role\":
+      \"assistant\",\n        \"content\": \"I now can give a great answer\\n\\nTo
+      calculate the area of a circle, we use the formula:\\n\\n\\\\[ A = \\\\pi r^2
+      \\\\]\\n\\nwhere \\\\( A \\\\) is the area, \\\\( \\\\pi \\\\) (approximately
+      3.14), and \\\\( r \\\\) is the radius of the circle.\\n\\nGiven that the radius
+      \\\\( r \\\\) is 5 cm, we can substitute this value into the formula:\\n\\n\\\\[
+      A = \\\\pi (5 \\\\, \\\\text{cm})^2 \\\\]\\n\\nCalculating this step-by-step:\\n\\n1.
+      First, square the radius:\\n   \\\\[ (5 \\\\, \\\\text{cm})^2 = 25 \\\\, \\\\text{cm}^2
+      \\\\]\\n\\n2. Then, multiply by \\\\( \\\\pi \\\\):\\n   \\\\[ A = \\\\pi \\\\times
+      25 \\\\, \\\\text{cm}^2 \\\\]\\n\\nUsing the approximate value of \\\\( \\\\pi
+      \\\\):\\n   \\\\[ A \\\\approx 3.14 \\\\times 25 \\\\, \\\\text{cm}^2 \\\\]\\n
+      \  \\\\[ A \\\\approx 78.5 \\\\, \\\\text{cm}^2 \\\\]\\n\\nThus, the area of
+      the circle is approximately 78.5 square centimeters.\\n\\nFinal Answer: The
+      calculated area of the circle is approximately 78.5 square centimeters.\",\n
+      \       \"refusal\": null\n      },\n      \"logprobs\": null,\n      \"finish_reason\":
+      \"stop\"\n    }\n  ],\n  \"usage\": {\n    \"prompt_tokens\": 182,\n    \"completion_tokens\":
+      270,\n    \"total_tokens\": 452,\n    \"completion_tokens_details\": {\n      \"reasoning_tokens\":
+      0\n    }\n  },\n  \"system_fingerprint\": \"fp_1bb46167f9\"\n}\n"
+    headers:
+      CF-Cache-Status:
+      - DYNAMIC
+      CF-RAY:
+      - 8c85da71fcac1cf3-GRU
+      Connection:
+      - keep-alive
+      Content-Encoding:
+      - gzip
+      Content-Type:
+      - application/json
+      Date:
+      - Tue, 24 Sep 2024 21:26:34 GMT
+      Server:
+      - cloudflare
+      Set-Cookie:
+      - __cf_bm=rb61BZH2ejzD5YPmLaEJqI7km71QqyNJGTVdNxBq6qk-1727213194-1.0.1.1-pJ49onmgX9IugEMuYQMralzD7oj_6W.CHbSu4Su1z3NyjTGYg.rhgJZWng8feFYah._oSnoYlkTjpK1Wd2C9FA;
+        path=/; expires=Tue, 24-Sep-24 21:56:34 GMT; domain=.api.openai.com; HttpOnly;
+        Secure; SameSite=None
+      - _cfuvid=lbRdAddVWV6W3f5Dm9SaOPWDUOxqtZBSPr_fTW26nEA-1727213194587-0.0.1.1-604800000;
+        path=/; domain=.api.openai.com; HttpOnly; Secure; SameSite=None
+      Transfer-Encoding:
+      - chunked
+      X-Content-Type-Options:
+      - nosniff
+      access-control-expose-headers:
+      - X-Request-ID
+      openai-organization:
+      - crewai-iuxna1
+      openai-processing-ms:
+      - '2244'
+      openai-version:
+      - '2020-10-01'
+      strict-transport-security:
+      - max-age=31536000; includeSubDomains; preload
+      x-ratelimit-limit-requests:
+      - '30000'
+      x-ratelimit-limit-tokens:
+      - '150000000'
+      x-ratelimit-remaining-requests:
+      - '29999'
+      x-ratelimit-remaining-tokens:
+      - '149999774'
+      x-ratelimit-reset-requests:
+      - 2ms
+      x-ratelimit-reset-tokens:
+      - 0s
+      x-request-id:
+      - req_2e565b5f24c38968e4e923a47ecc6233
+    http_version: HTTP/1.1
+    status_code: 200
+version: 1

tests/crew_test.py

@@ -3480,12 +3480,10 @@ def test_crew_guardrail_feedback_in_context():
 
 @pytest.mark.vcr(filter_headers=["authorization"])
 def test_before_kickoff_callback():
-    from crewai.project import CrewBase, agent, before_kickoff, task
+    from crewai.project import CrewBase, agent, before_kickoff, crew, task
 
     @CrewBase
     class TestCrewClass:
-        from crewai.project import crew
-
         agents_config = None
         tasks_config = None
 
@@ -3512,7 +3510,7 @@ def test_before_kickoff_callback():
             task = Task(
                 description="Test task description",
                 expected_output="Test expected output",
-                agent=self.my_agent(),
+                agent=self.my_agent(),  # Use the agent instance
             )
             return task
 
@@ -3522,30 +3520,28 @@ def test_before_kickoff_callback():
 
     test_crew_instance = TestCrewClass()
 
-    test_crew = test_crew_instance.crew()
+    crew = test_crew_instance.crew()
 
     # Verify that the before_kickoff_callbacks are set
-    assert len(test_crew.before_kickoff_callbacks) == 1
+    assert len(crew.before_kickoff_callbacks) == 1
 
     # Prepare inputs
     inputs = {"initial": True}
 
     # Call kickoff
-    test_crew.kickoff(inputs=inputs)
+    crew.kickoff(inputs=inputs)
 
     # Check that the before_kickoff function was called and modified inputs
     assert test_crew_instance.inputs_modified
-    assert inputs.get("modified")
+    assert inputs.get("modified") == True
 
 
 @pytest.mark.vcr(filter_headers=["authorization"])
 def test_before_kickoff_without_inputs():
-    from crewai.project import CrewBase, agent, before_kickoff, task
+    from crewai.project import CrewBase, agent, before_kickoff, crew, task
 
     @CrewBase
     class TestCrewClass:
-        from crewai.project import crew
-
         agents_config = None
         tasks_config = None
 
@@ -3583,12 +3579,12 @@ def test_before_kickoff_without_inputs():
     # Instantiate the class
     test_crew_instance = TestCrewClass()
     # Build the crew
-    test_crew = test_crew_instance.crew()
+    crew = test_crew_instance.crew()
     # Verify that the before_kickoff_callback is registered
-    assert len(test_crew.before_kickoff_callbacks) == 1
+    assert len(crew.before_kickoff_callbacks) == 1
 
     # Call kickoff without passing inputs
-    test_crew.kickoff()
+    output = crew.kickoff()
 
     # Check that the before_kickoff function was called
     assert test_crew_instance.inputs_modified

tests/test_flow_default_override.py

@@ -1,112 +0,0 @@
-"""Test that persisted state properly overrides default values."""
-
-from crewai.flow.flow import Flow, FlowState, listen, start
-from crewai.flow.persistence import persist
-
-
-class PoemState(FlowState):
-    """Test state model with default values that should be overridden."""
-    sentence_count: int = 1000  # Default that should be overridden
-    has_set_count: bool = False  # Track whether we've set the count
-    poem_type: str = ""
-
-
-def test_default_value_override():
-    """Test that persisted state values override class defaults."""
-
-    @persist()
-    class PoemFlow(Flow[PoemState]):
-        initial_state = PoemState
-
-        @start()
-        def set_sentence_count(self):
-            if self.state.has_set_count and self.state.sentence_count == 2:
-                self.state.sentence_count = 3
-
-            elif self.state.has_set_count and self.state.sentence_count == 1000:
-                self.state.sentence_count = 1000
-
-            elif self.state.has_set_count and self.state.sentence_count == 5:
-                self.state.sentence_count = 5
-
-            else:
-                self.state.sentence_count = 2
-                self.state.has_set_count = True
-
-    # First run - should set sentence_count to 2
-    flow1 = PoemFlow()
-    flow1.kickoff()
-    original_uuid = flow1.state.id
-    assert flow1.state.sentence_count == 2
-
-    # Second run - should load sentence_count=2 instead of default 1000
-    flow2 = PoemFlow()
-    flow2.kickoff(inputs={"id": original_uuid})
-    assert flow2.state.sentence_count == 3  # Should load 2, not default 1000
-
-    # Fourth run - explicit override should work
-    flow3 = PoemFlow()
-    flow3.kickoff(inputs={
-        "id": original_uuid,
-        "has_set_count": True,
-        "sentence_count": 5,  # Override persisted value
-    })
-    assert flow3.state.sentence_count == 5  # Should use override value
-
-    # Third run - should not load sentence_count=2 instead of default 1000
-    flow4 = PoemFlow()
-    flow4.kickoff(inputs={"has_set_count": True})
-    assert flow4.state.sentence_count == 1000  # Should load 1000, not 2
-
-
-def test_multi_step_default_override():
-    """Test default value override with multiple start methods."""
-
-    @persist()
-    class MultiStepPoemFlow(Flow[PoemState]):
-        initial_state = PoemState
-
-        @start()
-        def set_sentence_count(self):
-            print("Setting sentence count")
-            if not self.state.has_set_count:
-                self.state.sentence_count = 3
-                self.state.has_set_count = True
-
-        @listen(set_sentence_count)
-        def set_poem_type(self):
-            print("Setting poem type")
-            if self.state.sentence_count == 3:
-                self.state.poem_type = "haiku"
-            elif self.state.sentence_count == 5:
-                self.state.poem_type = "limerick"
-            else:
-                self.state.poem_type = "free_verse"
-
-        @listen(set_poem_type)
-        def finished(self):
-            print("finished")
-
-    # First run - should set both sentence count and poem type
-    flow1 = MultiStepPoemFlow()
-    flow1.kickoff()
-    original_uuid = flow1.state.id
-    assert flow1.state.sentence_count == 3
-    assert flow1.state.poem_type == "haiku"
-
-    # Second run - should load persisted state and update poem type
-    flow2 = MultiStepPoemFlow()
-    flow2.kickoff(inputs={
-        "id": original_uuid,
-        "sentence_count": 5
-    })
-    assert flow2.state.sentence_count == 5
-    assert flow2.state.poem_type == "limerick"
-
-    # Third run - new flow without persisted state should use defaults
-    flow3 = MultiStepPoemFlow()
-    flow3.kickoff(inputs={
-        "id": original_uuid
-    })
-    assert flow3.state.sentence_count == 5
-    assert flow3.state.poem_type == "limerick"

tests/test_flow_persistence.py

@@ -1,13 +1,13 @@
 """Test flow state persistence functionality."""
 
 import os
-from typing import Dict
+from typing import Dict, Optional
 
 import pytest
 from pydantic import BaseModel
 
-from crewai.flow.flow import Flow, FlowState, listen, start
-from crewai.flow.persistence import persist
+from crewai.flow.flow import Flow, FlowState, start
+from crewai.flow.persistence import FlowPersistence, persist
 from crewai.flow.persistence.sqlite import SQLiteFlowPersistence
 
 
@@ -21,20 +21,20 @@ def test_persist_decorator_saves_state(tmp_path):
     """Test that @persist decorator saves state in SQLite."""
     db_path = os.path.join(tmp_path, "test_flows.db")
     persistence = SQLiteFlowPersistence(db_path)
-
+    
     class TestFlow(Flow[Dict[str, str]]):
         initial_state = dict()  # Use dict instance as initial state
-
+        
         @start()
         @persist(persistence)
         def init_step(self):
             self.state["message"] = "Hello, World!"
             self.state["id"] = "test-uuid"  # Ensure we have an ID for persistence
-
+    
     # Run flow and verify state is saved
     flow = TestFlow(persistence=persistence)
     flow.kickoff()
-
+    
     # Load state from DB and verify
     saved_state = persistence.load_state(flow.state["id"])
     assert saved_state is not None
@@ -45,20 +45,20 @@ def test_structured_state_persistence(tmp_path):
     """Test persistence with Pydantic model state."""
     db_path = os.path.join(tmp_path, "test_flows.db")
     persistence = SQLiteFlowPersistence(db_path)
-
+    
     class StructuredFlow(Flow[TestState]):
         initial_state = TestState
-
+        
         @start()
         @persist(persistence)
         def count_up(self):
             self.state.counter += 1
             self.state.message = f"Count is {self.state.counter}"
-
+    
     # Run flow and verify state changes are saved
     flow = StructuredFlow(persistence=persistence)
     flow.kickoff()
-
+    
     # Load and verify state
     saved_state = persistence.load_state(flow.state.id)
     assert saved_state is not None
@@ -70,107 +70,126 @@ def test_flow_state_restoration(tmp_path):
     """Test restoring flow state from persistence with various restoration methods."""
     db_path = os.path.join(tmp_path, "test_flows.db")
     persistence = SQLiteFlowPersistence(db_path)
-
+    
     # First flow execution to create initial state
     class RestorableFlow(Flow[TestState]):
-
+        initial_state = TestState
+        
         @start()
         @persist(persistence)
         def set_message(self):
-            if self.state.message == "":
-                self.state.message = "Original message"
-            if self.state.counter == 0:
-                self.state.counter = 42
-
+            self.state.message = "Original message"
+            self.state.counter = 42
+    
     # Create and persist initial state
     flow1 = RestorableFlow(persistence=persistence)
     flow1.kickoff()
     original_uuid = flow1.state.id
-
+    
     # Test case 1: Restore using restore_uuid with field override
-    flow2 = RestorableFlow(persistence=persistence)
-    flow2.kickoff(inputs={
-        "id": original_uuid,
-        "counter": 43
-    })
-
+    flow2 = RestorableFlow(
+        persistence=persistence,
+        restore_uuid=original_uuid,
+        counter=43,  # Override counter
+    )
+    
     # Verify state restoration and selective field override
     assert flow2.state.id == original_uuid
     assert flow2.state.message == "Original message"  # Preserved
     assert flow2.state.counter == 43  # Overridden
-
+    
     # Test case 2: Restore using kwargs['id']
-    flow3 = RestorableFlow(persistence=persistence)
-    flow3.kickoff(inputs={
-        "id": original_uuid,
-        "message": "Updated message"
-    })
-
+    flow3 = RestorableFlow(
+        persistence=persistence,
+        id=original_uuid,
+        message="Updated message",  # Override message
+    )
+    
     # Verify state restoration and selective field override
     assert flow3.state.id == original_uuid
-    assert flow3.state.counter == 43  # Preserved
+    assert flow3.state.counter == 42  # Preserved
     assert flow3.state.message == "Updated message"  # Overridden
+    
+    # Test case 3: Verify error on conflicting IDs
+    with pytest.raises(ValueError) as exc_info:
+        RestorableFlow(
+            persistence=persistence,
+            restore_uuid=original_uuid,
+            id="different-id",  # Conflict with restore_uuid
+        )
+    assert "Conflicting IDs provided" in str(exc_info.value)
+    
+    # Test case 4: Verify error on non-existent restore_uuid
+    with pytest.raises(ValueError) as exc_info:
+        RestorableFlow(
+            persistence=persistence,
+            restore_uuid="non-existent-uuid",
+        )
+    assert "No state found" in str(exc_info.value)
+    
+    # Test case 5: Allow new state creation with kwargs['id']
+    new_uuid = "new-flow-id"
+    flow4 = RestorableFlow(
+        persistence=persistence,
+        id=new_uuid,
+        message="New message",
+        counter=100,
+    )
+    
+    # Verify new state creation with provided ID
+    assert flow4.state.id == new_uuid
+    assert flow4.state.message == "New message"
+    assert flow4.state.counter == 100
 
 
 def test_multiple_method_persistence(tmp_path):
     """Test state persistence across multiple method executions."""
     db_path = os.path.join(tmp_path, "test_flows.db")
     persistence = SQLiteFlowPersistence(db_path)
-
+    
     class MultiStepFlow(Flow[TestState]):
+        initial_state = TestState
+        
         @start()
         @persist(persistence)
         def step_1(self):
-            if self.state.counter == 1:
-                self.state.counter = 99999
-                self.state.message = "Step 99999"
-            else:
-                self.state.counter = 1
-                self.state.message = "Step 1"
-
-        @listen(step_1)
+            self.state.counter = 1
+            self.state.message = "Step 1"
+        
+        @start()
         @persist(persistence)
         def step_2(self):
-            if self.state.counter == 1:
-                self.state.counter = 2
-                self.state.message = "Step 2"
-
+            self.state.counter = 2
+            self.state.message = "Step 2"
+    
     flow = MultiStepFlow(persistence=persistence)
     flow.kickoff()
-
-    flow2 = MultiStepFlow(persistence=persistence)
-    flow2.kickoff(inputs={"id": flow.state.id})
-
+    
     # Load final state
-    final_state = flow2.state
+    final_state = persistence.load_state(flow.state.id)
     assert final_state is not None
-    assert final_state.counter == 2
-    assert final_state.message == "Step 2"
+    assert final_state["counter"] == 2
+    assert final_state["message"] == "Step 2"
 
-    class NoPersistenceMultiStepFlow(Flow[TestState]):
+
+def test_persistence_error_handling(tmp_path):
+    """Test error handling in persistence operations."""
+    db_path = os.path.join(tmp_path, "test_flows.db")
+    persistence = SQLiteFlowPersistence(db_path)
+    
+    class InvalidFlow(Flow[TestState]):
+        # Missing id field in initial state
+        class InvalidState(BaseModel):
+            value: str = ""
+            
+        initial_state = InvalidState
+        
         @start()
         @persist(persistence)
-        def step_1(self):
-            if self.state.counter == 1:
-                self.state.counter = 99999
-                self.state.message = "Step 99999"
-            else:
-                self.state.counter = 1
-                self.state.message = "Step 1"
-
-        @listen(step_1)
-        def step_2(self):
-            if self.state.counter == 1:
-                self.state.counter = 2
-                self.state.message = "Step 2"
-
-    flow = NoPersistenceMultiStepFlow(persistence=persistence)
-    flow.kickoff()
-
-    flow2 = NoPersistenceMultiStepFlow(persistence=persistence)
-    flow2.kickoff(inputs={"id": flow.state.id})
-
-    # Load final state
-    final_state = flow2.state
-    assert final_state.counter == 99999
-    assert final_state.message == "Step 99999"
+        def will_fail(self):
+            self.state.value = "test"
+    
+    with pytest.raises(ValueError) as exc_info:
+        flow = InvalidFlow(persistence=persistence)
+    
+    assert "must have an 'id' field" in str(exc_info.value)

tests/utilities/test_converter.py

@@ -588,12 +588,3 @@ def test_converter_with_function_calling():
     assert output.name == "Eve"
     assert output.age == 35
     instructor.to_pydantic.assert_called_once()
-
-
-def test_generate_model_description_union_field():
-    class UnionModel(BaseModel):
-        field: int | str | None
-
-    description = generate_model_description(UnionModel)
-    expected_description = '{\n  "field": int | str | None\n}'
-    assert description == expected_description

uv.lock

@@ -1,6 +1,7 @@
 version = 1
 requires-python = ">=3.10, <3.13"
 resolution-markers = [
+
     "python_full_version < '3.11' and platform_system == 'Darwin' and sys_platform == 'darwin'",
     "python_full_version < '3.11' and platform_machine == 'aarch64' and platform_system == 'Linux' and sys_platform == 'darwin'",
     "(python_full_version < '3.11' and platform_machine != 'aarch64' and platform_system != 'Darwin' and sys_platform == 'darwin') or (python_full_version < '3.11' and platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform == 'darwin')",
@@ -36,7 +37,7 @@ resolution-markers = [
     "python_full_version >= '3.12.4' and platform_machine == 'aarch64' and platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform == 'linux'",
     "(python_full_version >= '3.12.4' and platform_machine != 'aarch64' and platform_system == 'Darwin' and sys_platform != 'darwin') or (python_full_version >= '3.12.4' and platform_system == 'Darwin' and sys_platform != 'darwin' and sys_platform != 'linux')",
     "python_full_version >= '3.12.4' and platform_machine == 'aarch64' and platform_system == 'Linux' and sys_platform != 'darwin' and sys_platform != 'linux'",
-    "(python_full_version >= '3.12.4' and platform_machine != 'aarch64' and platform_system != 'Darwin' and sys_platform != 'darwin') or (python_full_version >= '3.12.4' and platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'darwin' and sys_platform != 'linux')",
+    "(python_full_version >= '3.12.4' and platform_machine != 'aarch64' and platform_system != 'Darwin' and sys_platform != 'darwin') or (python_full_version >= '3.12.4' and platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'darwin' and sys_platform != 'linux')"
 ]
 
 [[package]]
@@ -198,15 +199,6 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/39/e3/893e8757be2612e6c266d9bb58ad2e3651524b5b40cf56761e985a28b13e/asgiref-3.8.1-py3-none-any.whl", hash = "sha256:3e1e3ecc849832fe52ccf2cb6686b7a55f82bb1d6aee72a58826471390335e47", size = 23828 },
 ]
 
-[[package]]
-name = "asn1crypto"
-version = "1.5.1"
-source = { registry = "https://pypi.org/simple" }
-sdist = { url = "https://files.pythonhosted.org/packages/de/cf/d547feed25b5244fcb9392e288ff9fdc3280b10260362fc45d37a798a6ee/asn1crypto-1.5.1.tar.gz", hash = "sha256:13ae38502be632115abf8a24cbe5f4da52e3b5231990aff31123c805306ccb9c", size = 121080 }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/c9/7f/09065fd9e27da0eda08b4d6897f1c13535066174cc023af248fc2a8d5e5a/asn1crypto-1.5.1-py2.py3-none-any.whl", hash = "sha256:db4e40728b728508912cbb3d44f19ce188f218e9eba635821bb4b68564f8fd67", size = 105045 },
-]
-
 [[package]]
 name = "asttokens"
 version = "2.4.1"
@@ -228,15 +220,6 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/a7/fa/e01228c2938de91d47b307831c62ab9e4001e747789d0b05baf779a6488c/async_timeout-4.0.3-py3-none-any.whl", hash = "sha256:7405140ff1230c310e51dc27b3145b9092d659ce68ff733fb0cefe3ee42be028", size = 5721 },
 ]
 
-[[package]]
-name = "atpublic"
-version = "5.0"
-source = { registry = "https://pypi.org/simple" }
-sdist = { url = "https://files.pythonhosted.org/packages/5d/18/b1d247792440378abeeb0853f9daa2a127284b68776af6815990be7fcdb0/atpublic-5.0.tar.gz", hash = "sha256:d5cb6cbabf00ec1d34e282e8ce7cbc9b74ba4cb732e766c24e2d78d1ad7f723f", size = 14646 }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/6b/03/2cb0e5326e19b7d877bc9c3a7ef436a30a06835b638580d1f5e21a0409ed/atpublic-5.0-py3-none-any.whl", hash = "sha256:b651dcd886666b1042d1e38158a22a4f2c267748f4e97fde94bc492a4a28a3f3", size = 5207 },
-]
-
 [[package]]
 name = "attrs"
 version = "24.2.0"
@@ -363,7 +346,7 @@ name = "build"
 version = "1.2.2.post1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "colorama", marker = "os_name == 'nt'" },
+    { name = "colorama", marker = "(os_name == 'nt' and platform_machine != 'aarch64' and sys_platform == 'linux') or (os_name == 'nt' and sys_platform != 'darwin' and sys_platform != 'linux')" },
     { name = "importlib-metadata", marker = "python_full_version < '3.10.2'" },
     { name = "packaging" },
     { name = "pyproject-hooks" },
@@ -598,7 +581,7 @@ name = "click"
 version = "8.1.7"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "colorama", marker = "platform_system == 'Windows'" },
+    { name = "colorama", marker = "sys_platform == 'win32'" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/96/d3/f04c7bfcf5c1862a2a5b845c6b2b360488cf47af55dfa79c98f6a6bf98b5/click-8.1.7.tar.gz", hash = "sha256:ca9853ad459e787e2192211578cc907e7594e294c7ccc834310722b41b9ca6de", size = 336121 }
 wheels = [
@@ -649,7 +632,7 @@ wheels = [
 
 [[package]]
 name = "crewai"
-version = "0.98.0"
+version = "0.95.0"
 source = { editable = "." }
 dependencies = [
     { name = "appdirs" },
@@ -732,7 +715,7 @@ requires-dist = [
     { name = "blinker", specifier = ">=1.9.0" },
     { name = "chromadb", specifier = ">=0.5.23" },
     { name = "click", specifier = ">=8.1.7" },
-    { name = "crewai-tools", marker = "extra == 'tools'", specifier = ">=0.32.1" },
+    { name = "crewai-tools", marker = "extra == 'tools'", specifier = ">=0.25.5" },
     { name = "docling", marker = "extra == 'docling'", specifier = ">=2.12.0" },
     { name = "fastembed", marker = "extra == 'fastembed'", specifier = ">=0.4.1" },
     { name = "instructor", specifier = ">=1.3.3" },
@@ -780,7 +763,7 @@ dev = [
 
 [[package]]
 name = "crewai-tools"
-version = "0.32.1"
+version = "0.25.6"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "beautifulsoup4" },
@@ -792,21 +775,20 @@ dependencies = [
     { name = "lancedb" },
     { name = "linkup-sdk" },
     { name = "openai" },
-    { name = "patronus" },
     { name = "pydantic" },
     { name = "pyright" },
+    { name = "pytest" },
     { name = "pytube" },
     { name = "requests" },
     { name = "scrapegraph-py" },
     { name = "selenium" },
     { name = "serpapi" },
-    { name = "snowflake" },
     { name = "spider-client" },
     { name = "weaviate-client" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/e9/e7/fb07f0089028f7c9003770641d21f5844d4fa22bf5cc4c4b3676bfa0e1fe/crewai_tools-0.32.1.tar.gz", hash = "sha256:41acea9243b17a463f355d48dfe7d73bd59738c8862a8da780eae008e0136414", size = 887378 }
+sdist = { url = "https://files.pythonhosted.org/packages/23/2f/fbfd0dc8912d375a2d1272c503f79c83c25f3d2b4b72c230b0672278a1bd/crewai_tools-0.25.6.tar.gz", hash = "sha256:442a7e7e579cb3c671a53c5b7afce645cd31d2db913ecc6d1e22a4c5e1baa840", size = 883175 }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/36/f0/8f98f1a2b90b9b989bd01cf48b5e3bb2d842be2062bfd3177a77561e7b61/crewai_tools-0.32.1-py3-none-any.whl", hash = "sha256:6cb436dc66e19e35285a4fce501158a13bce99b244370574f568ec33c5513351", size = 537264 },
+    { url = "https://files.pythonhosted.org/packages/ce/21/561a81b4f8cfcc2ac6a0c3db3ec86b70a7db6dabb0dd7d13c96be981b2fc/crewai_tools-0.25.6-py3-none-any.whl", hash = "sha256:463e0ee8d780ab7a801992e3960471fb8e64d038866429f70995ddd0a83e0679", size = 514758 },
 ]
 
 [[package]]
@@ -2606,7 +2588,7 @@ version = "1.6.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "click" },
-    { name = "colorama", marker = "platform_system == 'Windows'" },
+    { name = "colorama", marker = "sys_platform == 'win32'" },
     { name = "ghp-import" },
     { name = "jinja2" },
     { name = "markdown" },
@@ -2787,7 +2769,7 @@ version = "2.10.2"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "pygments" },
-    { name = "pywin32", marker = "platform_system == 'Windows'" },
+    { name = "pywin32", marker = "sys_platform == 'win32'" },
     { name = "tqdm" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/3a/93/80ac75c20ce54c785648b4ed363c88f148bf22637e10c9863db4fbe73e74/mpire-2.10.2.tar.gz", hash = "sha256:f66a321e93fadff34585a4bfa05e95bd946cf714b442f51c529038eb45773d97", size = 271270 }
@@ -3034,7 +3016,7 @@ name = "nvidia-cudnn-cu12"
 version = "9.1.0.70"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "nvidia-cublas-cu12", marker = "(platform_machine != 'aarch64' and platform_system != 'Darwin') or (platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'linux')" },
+    { name = "nvidia-cublas-cu12", marker = "(platform_machine != 'aarch64' and platform_system != 'Darwin') or (platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'linux')" }
 ]
 wheels = [
     { url = "https://files.pythonhosted.org/packages/9f/fd/713452cd72343f682b1c7b9321e23829f00b842ceaedcda96e742ea0b0b3/nvidia_cudnn_cu12-9.1.0.70-py3-none-manylinux2014_x86_64.whl", hash = "sha256:165764f44ef8c61fcdfdfdbe769d687e06374059fbb388b6c89ecb0e28793a6f", size = 664752741 },
@@ -3063,7 +3045,7 @@ source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "nvidia-cublas-cu12", marker = "(platform_machine != 'aarch64' and platform_system != 'Darwin') or (platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'linux')" },
     { name = "nvidia-cusparse-cu12", marker = "(platform_machine != 'aarch64' and platform_system != 'Darwin') or (platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'linux')" },
-    { name = "nvidia-nvjitlink-cu12", marker = "(platform_machine != 'aarch64' and platform_system != 'Darwin') or (platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'linux')" },
+    { name = "nvidia-nvjitlink-cu12", marker = "(platform_machine != 'aarch64' and platform_system != 'Darwin') or (platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'linux')" }
 ]
 wheels = [
     { url = "https://files.pythonhosted.org/packages/bc/1d/8de1e5c67099015c834315e333911273a8c6aaba78923dd1d1e25fc5f217/nvidia_cusolver_cu12-11.4.5.107-py3-none-manylinux1_x86_64.whl", hash = "sha256:8a7ec542f0412294b15072fa7dab71d31334014a69f953004ea7a118206fe0dd", size = 124161928 },
@@ -3074,7 +3056,7 @@ name = "nvidia-cusparse-cu12"
 version = "12.1.0.106"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "nvidia-nvjitlink-cu12", marker = "(platform_machine != 'aarch64' and platform_system != 'Darwin') or (platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'linux')" },
+    { name = "nvidia-nvjitlink-cu12", marker = "(platform_machine != 'aarch64' and platform_system != 'Darwin') or (platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'linux')" }
 ]
 wheels = [
     { url = "https://files.pythonhosted.org/packages/65/5b/cfaeebf25cd9fdec14338ccb16f6b2c4c7fa9163aefcf057d86b9cc248bb/nvidia_cusparse_cu12-12.1.0.106-py3-none-manylinux1_x86_64.whl", hash = "sha256:f3b50f42cf363f86ab21f720998517a659a48131e8d538dc02f8768237bd884c", size = 195958278 },
@@ -3514,24 +3496,6 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/cc/20/ff623b09d963f88bfde16306a54e12ee5ea43e9b597108672ff3a408aad6/pathspec-0.12.1-py3-none-any.whl", hash = "sha256:a0d503e138a4c123b27490a4f7beda6a01c6f288df0e4a8b79c7eb0dc7b4cc08", size = 31191 },
 ]
 
-[[package]]
-name = "patronus"
-version = "0.0.17"
-source = { registry = "https://pypi.org/simple" }
-dependencies = [
-    { name = "httpx" },
-    { name = "pandas" },
-    { name = "pydantic" },
-    { name = "pydantic-settings" },
-    { name = "pyyaml" },
-    { name = "tqdm" },
-    { name = "typing-extensions" },
-]
-sdist = { url = "https://files.pythonhosted.org/packages/c5/a0/d5218ff6f2eab18c5a90266d21cdac673c85070e82e3f8aba538b3200f54/patronus-0.0.17.tar.gz", hash = "sha256:7298f770d4f6774b955806fb319c2c872fda3551bd7fa63d975bbeedc14b28de", size = 27377 }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/0e/9e/717c4508d675549ff081a7fecf25af7d70f9d7ad87ea0d4825e02de3b801/patronus-0.0.17-py3-none-any.whl", hash = "sha256:1f322eeee838974515fdb7cbf8530ad25c6c59686abbcb28c1fdbf23d34eb10d", size = 31516 },
-]
-
 [[package]]
 name = "pdfminer-six"
 version = "20231228"
@@ -3642,7 +3606,7 @@ name = "portalocker"
 version = "2.10.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "pywin32", marker = "platform_system == 'Windows'" },
+    { name = "pywin32", marker = "sys_platform == 'win32'" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/ed/d3/c6c64067759e87af98cc668c1cc75171347d0f1577fab7ca3749134e3cd4/portalocker-2.10.1.tar.gz", hash = "sha256:ef1bf844e878ab08aee7e40184156e1151f228f103aa5c6bd0724cc330960f8f", size = 40891 }
 wheels = [
@@ -4092,18 +4056,6 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/c2/35/c0edf199257ef0a7d407d29cd51c4e70d1dad4370a5f44deb65a7a5475e2/pymdown_extensions-10.11.2-py3-none-any.whl", hash = "sha256:41cdde0a77290e480cf53892f5c5e50921a7ee3e5cd60ba91bf19837b33badcf", size = 259044 },
 ]
 
-[[package]]
-name = "pyopenssl"
-version = "24.3.0"
-source = { registry = "https://pypi.org/simple" }
-dependencies = [
-    { name = "cryptography" },
-]
-sdist = { url = "https://files.pythonhosted.org/packages/c1/d4/1067b82c4fc674d6f6e9e8d26b3dff978da46d351ca3bac171544693e085/pyopenssl-24.3.0.tar.gz", hash = "sha256:49f7a019577d834746bc55c5fce6ecbcec0f2b4ec5ce1cf43a9a173b8138bb36", size = 178944 }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/42/22/40f9162e943f86f0fc927ebc648078be87def360d9d8db346619fb97df2b/pyOpenSSL-24.3.0-py3-none-any.whl", hash = "sha256:e474f5a473cd7f92221cc04976e48f4d11502804657a08a989fb3be5514c904a", size = 56111 },
-]
-
 [[package]]
 name = "pypdf"
 version = "5.0.1"
@@ -4972,87 +4924,6 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/e9/44/75a9c9421471a6c4805dbf2356f7c181a29c1879239abab1ea2cc8f38b40/sniffio-1.3.1-py3-none-any.whl", hash = "sha256:2f6da418d1f1e0fddd844478f41680e794e6051915791a034ff65e5f100525a2", size = 10235 },
 ]
 
-[[package]]
-name = "snowflake"
-version = "1.0.2"
-source = { registry = "https://pypi.org/simple" }
-dependencies = [
-    { name = "snowflake-core" },
-    { name = "snowflake-legacy" },
-]
-sdist = { url = "https://files.pythonhosted.org/packages/80/d1/830929fb7b54586f4ee601f409e80343e16f32b9b579246cd6fa9984bcff/snowflake-1.0.2.tar.gz", hash = "sha256:4009e59af24e444de4a9e9d340fff0979cca8a02a4feee4665da97eb9c76d958", size = 6033 }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/b6/25/4cbba4da3f9b333d132680a66221d1a101309cce330fa8be38b674ceafd0/snowflake-1.0.2-py3-none-any.whl", hash = "sha256:6bb0fc70aa10234769202861ccb4b091f5e9fb1bbc61a1e708db93baa3f221f4", size = 5623 },
-]
-
-[[package]]
-name = "snowflake-connector-python"
-version = "3.12.4"
-source = { registry = "https://pypi.org/simple" }
-dependencies = [
-    { name = "asn1crypto" },
-    { name = "certifi" },
-    { name = "cffi" },
-    { name = "charset-normalizer" },
-    { name = "cryptography" },
-    { name = "filelock" },
-    { name = "idna" },
-    { name = "packaging" },
-    { name = "platformdirs" },
-    { name = "pyjwt" },
-    { name = "pyopenssl" },
-    { name = "pytz" },
-    { name = "requests" },
-    { name = "sortedcontainers" },
-    { name = "tomlkit" },
-    { name = "typing-extensions" },
-]
-sdist = { url = "https://files.pythonhosted.org/packages/6b/de/f43d9c827ccc1974696ffd3c0495e2d4e98b0414b2353b7de932621f23dd/snowflake_connector_python-3.12.4.tar.gz", hash = "sha256:289e0691dfbf8ec8b7a8f58bcbb95a819890fe5e5b278fdbfc885059a63a946f", size = 743445 }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/53/6c/edc8909e424654a7a3c18cbf804d8a35c17a65a2131f866a87ed8e762bd0/snowflake_connector_python-3.12.4-cp310-cp310-macosx_11_0_arm64.whl", hash = "sha256:6f141c159e3244bd660279f87f32e39351b2845fcb75f8138f31d2219f983b05", size = 958038 },
-    { url = "https://files.pythonhosted.org/packages/93/a3/34c5082dfb9b555c914f4233224b8bc1f2c4d5668bc71bb587680b8dcd73/snowflake_connector_python-3.12.4-cp310-cp310-macosx_11_0_x86_64.whl", hash = "sha256:091458ba777c24adff659c5c28f0f5bb0bcca8a9b6ecc5641ae25b7c20a8f43d", size = 970665 },
-    { url = "https://files.pythonhosted.org/packages/f8/87/9eceaaba58b2ec4f9094fc3a04d953bbabbfdcc05a6b14ef12610c1039f9/snowflake_connector_python-3.12.4-cp310-cp310-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:23049d341da681ec7131cead71cdf7b1761ae5bcc08bcbdb931dcef6c25e8a5f", size = 2496731 },
-    { url = "https://files.pythonhosted.org/packages/66/0a/e35e9e0a142f3779007b0246166a245305858b198ed0dd3a41a3d2405512/snowflake_connector_python-3.12.4-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:cc88a09d77a8ce7e445094b2409b606ddb208b5fc9f7c7a379d0255a8d566e9d", size = 2520041 },
-    { url = "https://files.pythonhosted.org/packages/79/77/9a238c153600adff8fbd1136d9f4be1e42cb827cbe1865924bfe84653e85/snowflake_connector_python-3.12.4-cp310-cp310-win_amd64.whl", hash = "sha256:3c33fbba036805c1767ea48eb40ffc3fb79d61f2a4bb4e77b571ea6f6a998be8", size = 918272 },
-    { url = "https://files.pythonhosted.org/packages/0d/95/e8aac28d6913e4b59f96e6d361f31b9576b5f0abe4d2c4f7decf9f075932/snowflake_connector_python-3.12.4-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:2ec5cfaa1526084cf4d0e7849d5ace601245cb4ad9675ab3cd7d799b3abea481", size = 958125 },
-    { url = "https://files.pythonhosted.org/packages/67/b6/a847a94e03bdf39010048feacd57f250a91a655eed333d7d32b165f65201/snowflake_connector_python-3.12.4-cp311-cp311-macosx_11_0_x86_64.whl", hash = "sha256:ff225824b3a0fa5e822442de72172f97028f04ae183877f1305d538d8d6c5d11", size = 970770 },
-    { url = "https://files.pythonhosted.org/packages/0e/91/f97812ae9946944bcd9bfe1965af1cb9b1844919da879d90b90dfd3e5086/snowflake_connector_python-3.12.4-cp311-cp311-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:a9beced2789dc75e8f1e749aa637e7ec9b03302b4ed4b793ae0f1ff32823370e", size = 2519875 },
-    { url = "https://files.pythonhosted.org/packages/37/52/500d72079bfb322ebdf3892180ecf3dc73c117b3a966ee8d4bb1378882b2/snowflake_connector_python-3.12.4-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:5ea47450a04ff713f3adf28053e34103bd990291e62daee9721c76597af4b2b5", size = 2542320 },
-    { url = "https://files.pythonhosted.org/packages/59/92/74ead6bee8dd29fe372002ce59477221e04b9da96ad7aafe584afce02937/snowflake_connector_python-3.12.4-cp311-cp311-win_amd64.whl", hash = "sha256:748f9125854dca07ea471bb2bb3c5bb932a53f9b8a77ba348b50b738c77203ce", size = 918363 },
-    { url = "https://files.pythonhosted.org/packages/a5/a3/1cbe0b52b810f069bdc96c372b2d91ac51aeac32986c2832aa3fe0b0b0e5/snowflake_connector_python-3.12.4-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:4bcd0371b20d199f15e6a3c0b489bf18e27f2a88c84cf3194b2569ca039fa7d1", size = 957561 },
-    { url = "https://files.pythonhosted.org/packages/f4/05/8a5e16bd908a89f36d59686d356890c4bd6a976a487f86274181010f4b49/snowflake_connector_python-3.12.4-cp312-cp312-macosx_11_0_x86_64.whl", hash = "sha256:7900d82a450b206fa2ed6c42cd65d9b3b9fd4547eca1696937175fac2a03ba37", size = 969045 },
-    { url = "https://files.pythonhosted.org/packages/79/1b/8f5ab15d224d7bf76533c55cfd8ce73b185ce94d84241f0e900739ce3f37/snowflake_connector_python-3.12.4-cp312-cp312-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:300f0562aeea55e40ee03b45205dbef7b78f5ba2f1787a278c7b807e7d8db22c", size = 2533969 },
-    { url = "https://files.pythonhosted.org/packages/6e/d9/2e2fd72e0251691b5c54a219256c455141a2d3c104e411b82de598c62553/snowflake_connector_python-3.12.4-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:a6762a00948f003be55d7dc5de9de690315d01951a94371ec3db069d9303daba", size = 2558052 },
-    { url = "https://files.pythonhosted.org/packages/e8/cb/e0ab230ad5adc9932e595bdbec693b2499d446666daf6cb9cae306a41dd2/snowflake_connector_python-3.12.4-cp312-cp312-win_amd64.whl", hash = "sha256:83ca896790a7463b6c8cd42e1a29b8ea197cc920839ae6ee96a467475eab4ec2", size = 916627 },
-]
-
-[[package]]
-name = "snowflake-core"
-version = "1.0.2"
-source = { registry = "https://pypi.org/simple" }
-dependencies = [
-    { name = "atpublic" },
-    { name = "pydantic" },
-    { name = "python-dateutil" },
-    { name = "pyyaml" },
-    { name = "requests" },
-    { name = "snowflake-connector-python" },
-    { name = "urllib3" },
-]
-sdist = { url = "https://files.pythonhosted.org/packages/1d/cf/6f91e5b2daaf3df9ae666a65f5ba3938f11a40784e4ada5218ecf154b29a/snowflake_core-1.0.2.tar.gz", hash = "sha256:8bf267ff1efcd17f157432c6e24f6d2eb6c2aeed66f43ab34b215aa76d8edf02", size = 1092618 }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/75/3c/ec228b7325b32781081c72254dd0ef793943e853d82616e862e231909c6c/snowflake_core-1.0.2-py3-none-any.whl", hash = "sha256:55c37cf526a0d78dd3359ad96b9ecd7130bbbbc2f5a2fec77bb3da0dac2dc688", size = 1555690 },
-]
-
-[[package]]
-name = "snowflake-legacy"
-version = "1.0.0"
-source = { registry = "https://pypi.org/simple" }
-sdist = { url = "https://files.pythonhosted.org/packages/94/41/a6211bd2109913eee1506d37865ab13cf9a8cc2faa41833da3d1ffec654b/snowflake_legacy-1.0.0.tar.gz", hash = "sha256:2044661c79ba01841ab279c5e74b994532244c9d103224eba16eb159c8ed6033", size = 4043 }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/aa/8c/64f9b5ee0c3f376a733584c480b31addbf2baff7bb41f655e5e3f3719d3b/snowflake_legacy-1.0.0-py3-none-any.whl", hash = "sha256:25f9678f180d7d5f5b60d17f8112f0ee8a7a77b82c67fd599ed6e27bd502be5a", size = 3059 },
-]
-
 [[package]]
 name = "sortedcontainers"
 version = "2.4.0"
@@ -5314,15 +5185,6 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/c4/ac/ce90573ba446a9bbe65838ded066a805234d159b4446ae9f8ec5bbd36cbd/tomli_w-1.1.0-py3-none-any.whl", hash = "sha256:1403179c78193e3184bfaade390ddbd071cba48a32a2e62ba11aae47490c63f7", size = 6440 },
 ]
 
-[[package]]
-name = "tomlkit"
-version = "0.13.2"
-source = { registry = "https://pypi.org/simple" }
-sdist = { url = "https://files.pythonhosted.org/packages/b1/09/a439bec5888f00a54b8b9f05fa94d7f901d6735ef4e55dcec9bc37b5d8fa/tomlkit-0.13.2.tar.gz", hash = "sha256:fff5fe59a87295b278abd31bec92c15d9bc4a06885ab12bcea52c71119392e79", size = 192885 }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/f9/b6/a447b5e4ec71e13871be01ba81f5dfc9d0af7e473da256ff46bc0e24026f/tomlkit-0.13.2-py3-none-any.whl", hash = "sha256:7a974427f6e119197f670fbbbeae7bef749a6c14e793db934baefc1b5f03efde", size = 37955 },
-]
-
 [[package]]
 name = "torch"
 version = "2.4.1"
@@ -5332,19 +5194,19 @@ dependencies = [
     { name = "fsspec" },
     { name = "jinja2" },
     { name = "networkx" },
-    { name = "nvidia-cublas-cu12", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
-    { name = "nvidia-cuda-cupti-cu12", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
-    { name = "nvidia-cuda-nvrtc-cu12", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
-    { name = "nvidia-cuda-runtime-cu12", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
-    { name = "nvidia-cudnn-cu12", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
-    { name = "nvidia-cufft-cu12", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
-    { name = "nvidia-curand-cu12", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
-    { name = "nvidia-cusolver-cu12", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
-    { name = "nvidia-cusparse-cu12", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
-    { name = "nvidia-nccl-cu12", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
-    { name = "nvidia-nvtx-cu12", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
+    { name = "nvidia-cublas-cu12", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
+    { name = "nvidia-cuda-cupti-cu12", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
+    { name = "nvidia-cuda-nvrtc-cu12", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
+    { name = "nvidia-cuda-runtime-cu12", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
+    { name = "nvidia-cudnn-cu12", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
+    { name = "nvidia-cufft-cu12", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
+    { name = "nvidia-curand-cu12", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
+    { name = "nvidia-cusolver-cu12", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
+    { name = "nvidia-cusparse-cu12", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
+    { name = "nvidia-nccl-cu12", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
+    { name = "nvidia-nvtx-cu12", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
     { name = "sympy" },
-    { name = "triton", marker = "platform_machine == 'x86_64' and platform_system == 'Linux'" },
+    { name = "triton", marker = "platform_machine == 'x86_64' and sys_platform == 'linux'" },
     { name = "typing-extensions" },
 ]
 wheels = [
@@ -5391,7 +5253,7 @@ name = "tqdm"
 version = "4.66.5"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "colorama", marker = "platform_system == 'Windows'" },
+    { name = "colorama", marker = "sys_platform == 'win32'" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/58/83/6ba9844a41128c62e810fddddd72473201f3eacde02046066142a2d96cc5/tqdm-4.66.5.tar.gz", hash = "sha256:e1020aef2e5096702d8a025ac7d16b1577279c9d63f8375b63083e9a5f0fcbad", size = 169504 }
 wheels = [
@@ -5434,7 +5296,7 @@ version = "0.27.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "attrs" },
-    { name = "cffi", marker = "implementation_name != 'pypy' and os_name == 'nt'" },
+    { name = "cffi", marker = "(implementation_name != 'pypy' and os_name == 'nt' and platform_machine != 'aarch64' and sys_platform == 'linux') or (implementation_name != 'pypy' and os_name == 'nt' and sys_platform != 'darwin' and sys_platform != 'linux')" },
     { name = "exceptiongroup", marker = "python_full_version < '3.11'" },
     { name = "idna" },
     { name = "outcome" },
@@ -5465,7 +5327,7 @@ name = "triton"
 version = "3.0.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "filelock", marker = "(platform_machine != 'aarch64' and platform_system != 'Darwin') or (platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'linux')" },
+    { name = "filelock", marker = "(platform_machine != 'aarch64' and platform_system != 'Darwin') or (platform_system != 'Darwin' and platform_system != 'Linux' and sys_platform != 'linux')" }
 ]
 wheels = [
     { url = "https://files.pythonhosted.org/packages/45/27/14cc3101409b9b4b9241d2ba7deaa93535a217a211c86c4cc7151fb12181/triton-3.0.0-1-cp310-cp310-manylinux2014_x86_64.manylinux_2_17_x86_64.whl", hash = "sha256:e1efef76935b2febc365bfadf74bcb65a6f959a9872e5bddf44cc9e0adce1e1a", size = 209376304 },