add trino to ci job and fix make test problem

Author: dingo4dev

.github/workflows/python-ci.yml

@@ -178,9 +178,36 @@ jobs:
         path: .coverage*
         include-hidden-files: true
 
+  integration-test-trino:
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@v6
+    - uses: actions/setup-python@v6
+      with:
+        python-version: '3.12'
+    - name: Install UV
+      uses: astral-sh/setup-uv@v7
+      with:
+        enable-cache: true
+    - name: Install system dependencies
+      run: sudo apt-get update && sudo apt-get install -y libkrb5-dev # for kerberos
+    - name: Install
+      run: make install
+    - name: Run trino integration tests with coverage
+      run: COVERAGE=1 make test-trino
+    - name: Show debug logs
+      if: ${{ failure() }}
+      run: docker compose -f dev/docker-compose-trino.yml logs
+    - name: Upload coverage data
+      uses: actions/upload-artifact@v4
+      with:
+        name: coverage-trino
+        path: .coverage*
+        include-hidden-files: true
+
   integration-coverage-report:
     runs-on: ubuntu-latest
-    needs: [integration-test, integration-test-s3, integration-test-adls, integration-test-gcs]
+    needs: [integration-test, integration-test-s3, integration-test-adls, integration-test-gcs, integration-test-trino]
     steps:
     - uses: actions/checkout@v6
     - uses: actions/setup-python@v6

tests/integration/test_trino.py

@@ -20,7 +20,7 @@
 
 import pyarrow as pa
 import pytest
-from sqlalchemy import Connection, inspect, text
+from sqlalchemy import Connection, text
 
 from pyiceberg.catalog import Catalog
 from pyiceberg.catalog.rest import RestCatalog
@@ -47,10 +47,10 @@ def test_schema_exists_in_trino(trino_rest_conn: Connection, catalog: RestCatalo
     catalog.create_namespace_if_not_exists(TEST_NAMESPACE_IDENTIFIER)
 
     assert catalog.namespace_exists(TEST_NAMESPACE_IDENTIFIER)
-    assert TEST_NAMESPACE_IDENTIFIER[0].lower() in inspect(trino_rest_conn).get_schema_names()
 
 
 @pytest.mark.trino
+@pytest.mark.integration
 @pytest.mark.parametrize(
     "transform",
     [

tests/integration/test_writes/test_writes.py

@@ -2148,6 +2148,7 @@ def test_uuid_partitioning(session_catalog: Catalog, spark: SparkSession, transf
     assert lhs == rhs
 
 
+@pytest.mark.integration
 def test_avro_compression_codecs(session_catalog: Catalog, arrow_table_with_null: pa.Table) -> None:
     identifier = "default.test_avro_compression_codecs"
     tbl = _create_table(session_catalog, identifier, schema=arrow_table_with_null.schema, data=[arrow_table_with_null])