diff --git a/bindings/python/pyproject.toml b/bindings/python/pyproject.toml index 7b2d3d591f..346ee168da 100644 --- a/bindings/python/pyproject.toml +++ b/bindings/python/pyproject.toml @@ -44,7 +44,7 @@ python-source = "python" ignore = ["F403", "F405"] [tool.hatch.envs.dev] -dependencies = ["maturin>=1.0,<2.0", "pytest>=8.3.2", "pyarrow>=17.0.0", "datafusion>=45", "pyiceberg[sql-sqlite]>=0.9.1"] +dependencies = ["maturin>=1.0,<2.0", "pytest>=8.3.2", "pyarrow==16.*", "datafusion==47.*", "pyiceberg[sql-sqlite]>=0.9.1"] [tool.hatch.envs.dev.scripts] build = "maturin build --out dist --sdist" diff --git a/bindings/python/tests/test_datafusion_table_provider.py b/bindings/python/tests/test_datafusion_table_provider.py index 915b787697..5c6a15eb78 100644 --- a/bindings/python/tests/test_datafusion_table_provider.py +++ b/bindings/python/tests/test_datafusion_table_provider.py @@ -27,8 +27,8 @@ import datafusion assert ( - datafusion.__version__ >= "45" -) # iceberg table provider only works for datafusion >= 45 + datafusion.__version__ >= "47" +) # iceberg table provider only works for datafusion >= 47 @pytest.fixture(scope="session") diff --git a/crates/integrations/datafusion/tests/integration_datafusion_test.rs b/crates/integrations/datafusion/tests/integration_datafusion_test.rs index c079dce865..cb2809d0be 100644 --- a/crates/integrations/datafusion/tests/integration_datafusion_test.rs +++ b/crates/integrations/datafusion/tests/integration_datafusion_test.rs @@ -440,7 +440,7 @@ async fn test_metadata_table() -> Result<()> { #[tokio::test] async fn test_insert_into() -> Result<()> { - let iceberg_catalog = get_iceberg_catalog(); + let iceberg_catalog = get_iceberg_catalog().await; let namespace = NamespaceIdent::new("test_insert_into".to_string()); set_test_namespace(&iceberg_catalog, &namespace).await?; @@ -553,7 +553,7 @@ fn get_nested_struct_type() -> StructType { #[tokio::test] async fn test_insert_into_nested() -> Result<()> { - let iceberg_catalog = get_iceberg_catalog(); + let iceberg_catalog = get_iceberg_catalog().await; let namespace = NamespaceIdent::new("test_insert_nested".to_string()); set_test_namespace(&iceberg_catalog, &namespace).await?; let table_name = "nested_table";