DBT-822 Support dbt-core 1.10.0 for dbt-hive

README.md

@@ -15,10 +15,10 @@ This code base is now being actively developed and maintained by Cloudera.
 
 ### Requirements
 
-Current version of dbt-hive uses dbt-core 1.9.*. We are actively working on supporting the next available version of dbt-core.
+Current version of dbt-hive 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.*
 impyla >= 0.18
 
 ### Install

dbt/adapters/hive/__version__.py

@@ -11,4 +11,4 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # 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

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

tests/functional/adapter/test_concurrency.py

@@ -1,23 +1,47 @@
+from collections import Counter
+
 import pytest
-from dbt.tests.util import run_dbt, check_relations_equal, rm_file, write_file
+
+from dbt.artifacts.schemas.results import RunStatus
+from dbt.tests.util import (
+    check_relations_equal,
+    check_table_does_not_exist,
+    rm_file,
+    run_dbt,
+    write_file,
+)
+
 from dbt.tests.adapter.concurrency.test_concurrency import BaseConcurrency, seeds__update_csv
 
 
 class TestConcurrencyHive(BaseConcurrency):
-    def test_concurrency_hive(self, project):
+    def test_concurrency(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"])
+        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`")
 
         rm_file(project.project_root, "seeds", "seed.csv")
-        write_file(seeds__update_csv, 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"])
+
+        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`")
+
+        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