May 28, 2025 · May 28, 2025 · May 28, 2025
diff --git a/.github/workflows/code-quality-checks.yml b/.github/workflows/code-quality-checks.yml
 name: Code Quality Checks
 on:
  push:
    branches:
      - main
      - sea-migration
      - telemetry
  pull_request:
    branches:
      - main
      - sea-migration
      - telemetry

 on: [pull_request]

 jobs:
  run-unit-tests:
    runs-on: ubuntu-latest
diff --git a/.github/workflows/integration.yml b/.github/workflows/integration.yml
 name: Integration Tests

 on:
  push:
    paths-ignore:
      - "**.MD"
      - "**.md"
  pull_request:
  push:
    branches:
      - main
      - sea-migration
      - telemetry
  pull_request:

 jobs:
  run-e2e-tests:
diff --git a/tests/e2e/test_complex_types.py b/tests/e2e/test_complex_types.py
            # Create the table
            cursor.execute(
                """
                CREATE TABLE IF NOT EXISTSpysql_test_complex_types_table (
                CREATE TABLE IF NOT EXISTSpysql_e2e_test_complex_types_table (
                    array_col ARRAY<STRING>,
                    map_col MAP<STRING, INTEGER>,
                    struct_col STRUCT<field1: STRING, field2: INTEGER>
            # Insert a record
            cursor.execute(
                """
                INSERT INTOpysql_test_complex_types_table
                INSERT INTOpysql_e2e_test_complex_types_table
                VALUES (
                    ARRAY('a', 'b', 'c'),
                    MAP('a', 1, 'b', 2, 'c', 3),
            )
            yield
            # Clean up the table after the test
            cursor.execute("DROP TABLE IF EXISTSpysql_test_complex_types_table")
            cursor.execute("DROP TABLE IF EXISTSpysql_e2e_test_complex_types_table")

    @pytest.mark.parametrize(
        "field,expected_type",

        with self.cursor() as cursor:
            result = cursor.execute(
                "SELECT * FROMpysql_test_complex_types_table LIMIT 1"
                "SELECT * FROMpysql_e2e_test_complex_types_table LIMIT 1"
            ).fetchone()

        assert isinstance(result[field], expected_type)
            extra_params={"_use_arrow_native_complex_types": False}
        ) as cursor:
            result = cursor.execute(
                "SELECT * FROMpysql_test_complex_types_table LIMIT 1"
                "SELECT * FROMpysql_e2e_test_complex_types_table LIMIT 1"
            ).fetchone()

        assert isinstance(result[field], str)
Original file line number	Diff line number	Diff line change
		@@ -1,15 +1,7 @@
		name: Code Quality Checks
		on:
		push:
		branches:
		- main
		- sea-migration
		- telemetry
		pull_request:
		branches:
		- main
		- sea-migration
		- telemetry

		on: [pull_request]

		jobs:
		run-unit-tests:
		runs-on: ubuntu-latest
Expand Down
Original file line number	Diff line number	Diff line change
		@@ -1,14 +1,10 @@
		name: Integration Tests

		on:
		push:
		paths-ignore:
		- "**.MD"
		- "**.md"
		pull_request:
		push:
		branches:
		- main
		- sea-migration
		- telemetry
		pull_request:

		jobs:
		run-e2e-tests:
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -14,7 +14,7 @@ def table_fixture(self, connection_details):
		# Create the table
		cursor.execute(
		"""
		CREATE TABLE IF NOT EXISTSpysql_test_complex_types_table (
		CREATE TABLE IF NOT EXISTSpysql_e2e_test_complex_types_table (
		array_col ARRAY<STRING>,
		map_col MAP<STRING, INTEGER>,
		struct_col STRUCT<field1: STRING, field2: INTEGER>
Expand All		@@ -24,7 +24,7 @@ def table_fixture(self, connection_details):
		# Insert a record
		cursor.execute(
		"""
		INSERT INTOpysql_test_complex_types_table
		INSERT INTOpysql_e2e_test_complex_types_table
		VALUES (
		ARRAY('a', 'b', 'c'),
		MAP('a', 1, 'b', 2, 'c', 3),
Expand All		@@ -34,7 +34,7 @@ def table_fixture(self, connection_details):
		)
		yield
		# Clean up the table after the test
		cursor.execute("DROP TABLE IF EXISTSpysql_test_complex_types_table")
		cursor.execute("DROP TABLE IF EXISTSpysql_e2e_test_complex_types_table")

		@pytest.mark.parametrize(
		"field,expected_type",
Expand All		@@ -45,7 +45,7 @@ def test_read_complex_types_as_arrow(self, field, expected_type, table_fixture):

		with self.cursor() as cursor:
		result = cursor.execute(
		"SELECT * FROMpysql_test_complex_types_table LIMIT 1"
		"SELECT * FROMpysql_e2e_test_complex_types_table LIMIT 1"
		).fetchone()

		assert isinstance(result[field], expected_type)
Expand All		@@ -57,7 +57,7 @@ def test_read_complex_types_as_string(self, field, table_fixture):
		extra_params={"_use_arrow_native_complex_types": False}
		) as cursor:
		result = cursor.execute(
		"SELECT * FROMpysql_test_complex_types_table LIMIT 1"
		"SELECT * FROMpysql_e2e_test_complex_types_table LIMIT 1"
		).fetchone()

		assert isinstance(result[field], str)