fix(sqlalchemy-bigquery): resolve ST function type binding bug and unskip geography tests

Author: ohmayr

packages/sqlalchemy-bigquery/sqlalchemy_bigquery/geography.py

@@ -183,9 +183,8 @@ def _fixup_st_arguments(element, compiler, **kw):
     argument_types = _argument_types.get(element.name.lower())
     if argument_types:
         for argument_type, argument in zip(argument_types, element.clauses.clauses):
-            if isinstance(argument, BindParameter) and (
-                argument.type is not argument_type
-                or not isinstance(argument.type, argument_type)
+            if isinstance(argument, BindParameter) and not isinstance(
+                argument.type, argument_type
             ):
                 argument.type = argument_type()
 

packages/sqlalchemy-bigquery/tests/unit/test_geography.py

@@ -24,8 +24,6 @@
 geoalchemy2 = pytest.importorskip("geoalchemy2")
 
 
-# TODO(http://github.com/googleapis/google-cloud-python/issues/17287): Unskip once bug is resolved.
-@pytest.mark.skip(reason="Failing in CI with AssertionError.")
 def test_geoalchemy2_core(faux_conn, last_query):
     """Make sure GeoAlchemy 2 Core Tutorial works as adapted to only having geometry"""
     conn = faux_conn
@@ -101,7 +99,7 @@ def test_geoalchemy2_core(faux_conn, last_query):
     last_query(
         "SELECT `lake`.`name` \n"
         "FROM `lake` \n"
-        "WHERE ST_Contains(`lake`.`geog`, %(ST_Contains_1:geography)s)",
+        "WHERE ST_Contains(`lake`.`geog`, %(ST_Contains_1:STRING)s)",
         {"ST_Contains_1": "POINT(4 1)"},
     )
 
@@ -183,3 +181,20 @@ def test_calling_st_functions_that_dont_take_geographies(faux_conn, last_query):
         " AS `ST_GeogFromText_1`",
         dict(ST_GeogFromText_2="point(0 0)"),
     )
+
+
+def test_fixup_st_arguments():
+    from sqlalchemy_bigquery.geography import _fixup_st_arguments, GEOGRAPHY
+    from geoalchemy2.functions import ST_Area
+    from sqlalchemy.sql.elements import BindParameter
+
+    func_element = ST_Area(BindParameter("param", "point(0 0)"))
+
+    class DummyCompiler:
+        def visit_function(self, element, **kw):
+            return "ST_Area(param)"
+
+    res = _fixup_st_arguments(func_element, DummyCompiler())
+    assert res == "ST_Area(param)"
+    assert isinstance(func_element.clauses.clauses[0].type, GEOGRAPHY)
+