DBT-823 Support dbt-core 1.10.0 for dbt-impala

Makefile

@@ -1,5 +1,5 @@
 .DEFAULT_GOAL := help
-PYTHON_VERSION ?= py38
+PYTHON_VERSION ?= py311
 
 # Define the name of the virtual environment directory
 VENV ?= .venv-dbt-impala

README.md

@@ -11,10 +11,10 @@ The `dbt-impala` adapter allows you to use [dbt](https://www.getdbt.com/) along
 
 ### Requirements
 
-Current version of dbt-impala uses dbt-core 1.9.*. We are actively working on supporting the next available version of dbt-core.
+Current version of dbt-impala uses dbt-core 1.10.*. We are actively working on supporting the next available version of dbt-core.
 
 Python >= 3.9
-dbt-core == 1.9.*
+dbt-core == 1.10.*
 
 For development/testing or contribution to the dbt-impala, please follow [Contributing](CONTRIBUTING.md) guidelines.
 

dbt/adapters/impala/__version__.py

@@ -12,4 +12,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-version = "1.9.0"
+version = "1.10.0"

dev-requirements.txt

@@ -1,4 +1,4 @@
-dbt-tests-adapter==1.9.*
+dbt-tests-adapter==1.10.*
 pre-commit~=2.21;python_version=="3.7"
 pre-commit~=3.2;python_version>="3.8"
 pytest

setup.py

@@ -46,7 +46,7 @@ def _get_dbt_core_version():
 
 package_name = "dbt-impala"
 # make sure this always matches dbt/adapters/dbt_impala/__version__.py
-package_version = "1.9.0"
+package_version = "1.10.0"
 description = """The Impala adapter plugin for dbt"""
 
 dbt_core_version = _get_dbt_core_version()

tests/functional/adapter/test_concurrency.py

@@ -1,34 +1,20 @@
+from collections import Counter
+
 import pytest
+
+from dbt.artifacts.schemas.results import RunStatus
 from dbt.tests.util import (
-    run_dbt,
     check_relations_equal,
+    check_table_does_not_exist,
     rm_file,
+    run_dbt,
     write_file,
-    check_table_does_not_exist,
-    run_dbt_and_capture,
 )
+
 from dbt.tests.adapter.concurrency.test_concurrency import BaseConcurrency, seeds__update_csv
 
 
 class TestConcurrencyImpala(BaseConcurrency):
-    def test_concurrency_impala(self, project):
-        run_dbt(["seed", "--select", "seed"])
-        results = run_dbt(["run"], expect_pass=False)
-        assert len(results) == 7
-        check_relations_equal(project.adapter, ["SEED", "VIEW_MODEL"])
-        check_relations_equal(project.adapter, ["SEED", "DEP"])
-        check_relations_equal(project.adapter, ["SEED", "TABLE_A"])
-        check_relations_equal(project.adapter, ["SEED", "TABLE_B"])
-
-        rm_file(project.project_root, "seeds", "seed.csv")
-        write_file(seeds__update_csv, project.project_root + "/seeds", "seed.csv")
-        results = run_dbt(["run"], expect_pass=False)
-        assert len(results) == 7
-        check_relations_equal(project.adapter, ["SEED", "VIEW_MODEL"])
-        check_relations_equal(project.adapter, ["SEED", "DEP"])
-        check_relations_equal(project.adapter, ["SEED", "TABLE_A"])
-        check_relations_equal(project.adapter, ["SEED", "TABLE_B"])
-
     def test_concurrency(self, project):
         run_dbt(["seed", "--select", "seed"])
         results = run_dbt(["run"], expect_pass=False)
@@ -43,13 +29,19 @@ def test_concurrency(self, project):
         rm_file(project.project_root, "seeds", "seed.csv")
         write_file(seeds__update_csv, project.project_root, "seeds", "seed.csv")
 
-        results, output = run_dbt_and_capture(["run"], expect_pass=False)
-        assert len(results) == 7
+        results = run_dbt(["run"], expect_pass=False)
+
         check_relations_equal(project.adapter, ["seed", "view_model"])
         check_relations_equal(project.adapter, ["seed", "dep"])
         check_relations_equal(project.adapter, ["seed", "table_a"])
         check_relations_equal(project.adapter, ["seed", "table_b"])
         check_table_does_not_exist(project.adapter, "invalid")
         check_table_does_not_exist(project.adapter, "`skip`")
 
-        assert "PASS=5 WARN=0 ERROR=1 SKIP=1 TOTAL=7" in output
+        result_statuses = Counter([result.status for result in results])
+        expected_statuses = {
+            RunStatus.Success: 5,
+            RunStatus.Error: 1,
+            RunStatus.Skipped: 1,
+        }
+        assert result_statuses == expected_statuses