fix: interpolate properly parameters in snowflake

setup.py

@@ -66,7 +66,7 @@ def get_static_file_paths():
 
 setup(
     name='toucan_connectors',
-    version='0.39.2',
+    version='0.39.3',
     description='Toucan Toco Connectors',
     long_description=(HERE / 'README.md').read_text(encoding='utf-8'),
     long_description_content_type='text/markdown',

tests/snowflake/test_snowflake.py

@@ -11,8 +11,8 @@
     domain='test_domain',
     database='test_database',
     warehouse='test_warehouse',
-    query='test_query with %(foo)s',
-    parameters={'foo': 'bar'},
+    query='test_query with %(foo)s and {{ pokemon }}',
+    parameters={'foo': 'bar', 'pokemon': 'pikachu'},
 )
 
 
@@ -35,7 +35,7 @@ def test_snowflake(mocker):
         ocsp_response_cache_filename=None,
     )
 
-    reasq.assert_called_once_with('test_query with %(foo)s', con=snock(), params={'foo': 'bar'})
+    reasq.assert_called_once_with('test_query with bar and pikachu', con=snock())
 
 
 def test_missing_cache_file():

toucan_connectors/snowflake/snowflake_connector.py

@@ -4,6 +4,7 @@
 import snowflake.connector
 from pydantic import Field, SecretStr, constr
 
+from toucan_connectors.common import nosql_apply_parameters_to_query
 from toucan_connectors.toucan_connector import ToucanConnector, ToucanDataSource
 
 
@@ -63,8 +64,8 @@ def _retrieve_data(self, data_source: SnowflakeDataSource) -> pd.DataFrame:
         # https://docs.snowflake.net/manuals/sql-reference/sql/use-warehouse.html
         connection.cursor().execute(f'USE WAREHOUSE {data_source.warehouse}')
 
-        query_params = data_source.parameters or {}
-        df = pd.read_sql(data_source.query, con=connection, params=query_params)
+        query = nosql_apply_parameters_to_query(data_source.query, data_source.parameters)
+        df = pd.read_sql(query, con=connection)
 
         connection.close()