From cc018bf1287d8325b1566951d52de49c8ec73882 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jo=C3=A3o=20Moura?= Date: Sun, 19 Jan 2025 00:34:07 -0800 Subject: [PATCH] updating tools version --- pyproject.toml | 9 +- src/crewai/cli/templates/flow/main.py | 2 +- src/crewai/flow/__init__.py | 6 +- src/crewai/flow/flow.py | 7 +- src/crewai/flow/persistence/decorators.py | 35 +++-- tests/test_flow_persistence.py | 60 ++++----- uv.lock | 149 +++++++++++++++++++++- 7 files changed, 200 insertions(+), 68 deletions(-) diff --git a/pyproject.toml b/pyproject.toml index aab5864fd..8dbe56fd8 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -13,25 +13,20 @@ 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", @@ -40,7 +35,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] @@ -49,7 +44,7 @@ Documentation = "https://docs.crewai.com" Repository = "https://github.com/crewAIInc/crewAI" [project.optional-dependencies] -tools = ["crewai-tools>=0.25.5"] +tools = ["crewai-tools>=0.32.1"] embeddings = [ "tiktoken~=0.7.0" ] diff --git a/src/crewai/cli/templates/flow/main.py b/src/crewai/cli/templates/flow/main.py index 83f48ddd6..920b56c04 100644 --- a/src/crewai/cli/templates/flow/main.py +++ b/src/crewai/cli/templates/flow/main.py @@ -3,7 +3,7 @@ from random import randint from pydantic import BaseModel -from crewai.flow.flow import Flow, listen, start +from crewai.flow import Flow, listen, start from {{folder_name}}.crews.poem_crew.poem_crew import PoemCrew diff --git a/src/crewai/flow/__init__.py b/src/crewai/flow/__init__.py index b8c530bc3..48a49666d 100644 --- a/src/crewai/flow/__init__.py +++ b/src/crewai/flow/__init__.py @@ -1,3 +1,5 @@ -from crewai.flow.flow import Flow +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"] -__all__ = ["Flow"] diff --git a/src/crewai/flow/flow.py b/src/crewai/flow/flow.py index ad91d1236..6f4d0cc86 100644 --- a/src/crewai/flow/flow.py +++ b/src/crewai/flow/flow.py @@ -63,14 +63,14 @@ def ensure_state_type(state: Any, expected_type: Type[StateT]) -> StateT: 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 @@ -612,7 +612,6 @@ class Flow(Generic[T], metaclass=FlowMeta): # 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)}" ) diff --git a/src/crewai/flow/persistence/decorators.py b/src/crewai/flow/persistence/decorators.py index 4906e95d5..473d36888 100644 --- a/src/crewai/flow/persistence/decorators.py +++ b/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,18 +23,15 @@ 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 @@ -48,23 +45,23 @@ T = TypeVar("T") 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]): @@ -79,18 +76,18 @@ def persist(persistence: Optional[FlowPersistence] = None): 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, @@ -102,11 +99,11 @@ def persist(persistence: Optional[FlowPersistence] = None): 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 class_methods = {} @@ -131,13 +128,13 @@ def persist(persistence: Optional[FlowPersistence] = None): _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(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) @@ -146,7 +143,7 @@ def persist(persistence: Optional[FlowPersistence] = None): # 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: @@ -173,5 +170,5 @@ def persist(persistence: Optional[FlowPersistence] = None): 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 diff --git a/tests/test_flow_persistence.py b/tests/test_flow_persistence.py index 74971f30d..0d1cfe3c3 100644 --- a/tests/test_flow_persistence.py +++ b/tests/test_flow_persistence.py @@ -7,7 +7,7 @@ import pytest from pydantic import BaseModel from crewai.flow.flow import Flow, FlowState, start -from crewai.flow.persistence import FlowPersistence, persist +from crewai.flow.persistence import 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,46 +70,46 @@ 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): 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, 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, 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 == 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( @@ -118,7 +118,7 @@ def test_flow_state_restoration(tmp_path): 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( @@ -126,7 +126,7 @@ def test_flow_state_restoration(tmp_path): 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( @@ -135,7 +135,7 @@ def test_flow_state_restoration(tmp_path): message="New message", counter=100, ) - + # Verify new state creation with provided ID assert flow4.state.id == new_uuid assert flow4.state.message == "New message" @@ -146,25 +146,25 @@ 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): self.state.counter = 1 self.state.message = "Step 1" - + @start() @persist(persistence) def step_2(self): self.state.counter = 2 self.state.message = "Step 2" - + flow = MultiStepFlow(persistence=persistence) flow.kickoff() - + # Load final state final_state = persistence.load_state(flow.state.id) assert final_state is not None @@ -176,20 +176,20 @@ 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 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) diff --git a/uv.lock b/uv.lock index 7aa81ea2b..f38c1d582 100644 --- a/uv.lock +++ b/uv.lock @@ -198,6 +198,15 @@ 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" @@ -219,6 +228,15 @@ 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" @@ -714,7 +732,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.25.5" }, + { name = "crewai-tools", marker = "extra == 'tools'", specifier = ">=0.32.1" }, { name = "docling", marker = "extra == 'docling'", specifier = ">=2.12.0" }, { name = "fastembed", marker = "extra == 'fastembed'", specifier = ">=0.4.1" }, { name = "instructor", specifier = ">=1.3.3" }, @@ -762,7 +780,7 @@ dev = [ [[package]] name = "crewai-tools" -version = "0.25.6" +version = "0.32.1" source = { registry = "https://pypi.org/simple" } dependencies = [ { name = "beautifulsoup4" }, @@ -774,20 +792,21 @@ 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/23/2f/fbfd0dc8912d375a2d1272c503f79c83c25f3d2b4b72c230b0672278a1bd/crewai_tools-0.25.6.tar.gz", hash = "sha256:442a7e7e579cb3c671a53c5b7afce645cd31d2db913ecc6d1e22a4c5e1baa840", size = 883175 } +sdist = { url = "https://files.pythonhosted.org/packages/e9/e7/fb07f0089028f7c9003770641d21f5844d4fa22bf5cc4c4b3676bfa0e1fe/crewai_tools-0.32.1.tar.gz", hash = "sha256:41acea9243b17a463f355d48dfe7d73bd59738c8862a8da780eae008e0136414", size = 887378 } wheels = [ - { url = "https://files.pythonhosted.org/packages/ce/21/561a81b4f8cfcc2ac6a0c3db3ec86b70a7db6dabb0dd7d13c96be981b2fc/crewai_tools-0.25.6-py3-none-any.whl", hash = "sha256:463e0ee8d780ab7a801992e3960471fb8e64d038866429f70995ddd0a83e0679", size = 514758 }, + { url = "https://files.pythonhosted.org/packages/36/f0/8f98f1a2b90b9b989bd01cf48b5e3bb2d842be2062bfd3177a77561e7b61/crewai_tools-0.32.1-py3-none-any.whl", hash = "sha256:6cb436dc66e19e35285a4fce501158a13bce99b244370574f568ec33c5513351", size = 537264 }, ] [[package]] @@ -3495,6 +3514,24 @@ 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" @@ -4055,6 +4092,18 @@ 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" @@ -4923,6 +4972,87 @@ 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" @@ -5184,6 +5314,15 @@ 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"