feat(query): add dialect parameter to query request (#174)

Co-authored-by: hotdata-automation[bot] <267177015+hotdata-automation[bot]@users.noreply.github.com>

Author: hotdata-automation[bot]

CHANGELOG.md

@@ -7,6 +7,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Changed
+
+- feat(query): add dialect parameter to query request
+
 ## [0.10.0] - 2026-08-18
 
 ### Removed

docs/QueryRequest.md

@@ -11,6 +11,7 @@ Name | Type | Description | Notes
 **database_id** | **str** | Database to scope the query to (its id). Alternative to the `X-Database-Id` header — exactly one source must be provided. If both this field and the header are set and they disagree, the request is rejected with a 400. | [optional] 
 **default_catalog** | **str** | Catalog that unqualified table references resolve against within the query's database scope. Must name a catalog visible in the database (`default`, an attached catalog alias, or a system catalog). Defaults to `default` when omitted. | [optional] 
 **default_schema** | **str** | Schema that unqualified table references resolve against within the query's database scope. Defaults to `main` when omitted. Existence is not validated up front — an unknown schema surfaces as a \"table not found\" error at planning time. | [optional] 
+**dialect** | **str** | SQL dialect the `sql` field is written in. One of `hotsql` (the default), `duckdb`, `postgres`, or `snowflake`. When set to anything other than `hotsql`, the query is translated to HotSQL before it runs, so you can use idioms from that dialect (for example Snowflake `IFF(...)` or Postgres `MOD(a, b)`). Only read-only queries are accepted. An unrecognized value is rejected with a 400. | [optional] 
 **sql** | **str** |  | 
 
 ## Example

hotdata/models/query_request.py

@@ -33,8 +33,9 @@ class QueryRequest(BaseModel):
     database_id: Optional[StrictStr] = Field(default=None, description="Database to scope the query to (its id). Alternative to the `X-Database-Id` header — exactly one source must be provided. If both this field and the header are set and they disagree, the request is rejected with a 400.")
     default_catalog: Optional[StrictStr] = Field(default=None, description="Catalog that unqualified table references resolve against within the query's database scope. Must name a catalog visible in the database (`default`, an attached catalog alias, or a system catalog). Defaults to `default` when omitted.")
     default_schema: Optional[StrictStr] = Field(default=None, description="Schema that unqualified table references resolve against within the query's database scope. Defaults to `main` when omitted. Existence is not validated up front — an unknown schema surfaces as a \"table not found\" error at planning time.")
+    dialect: Optional[StrictStr] = Field(default=None, description="SQL dialect the `sql` field is written in. One of `hotsql` (the default), `duckdb`, `postgres`, or `snowflake`. When set to anything other than `hotsql`, the query is translated to HotSQL before it runs, so you can use idioms from that dialect (for example Snowflake `IFF(...)` or Postgres `MOD(a, b)`). Only read-only queries are accepted. An unrecognized value is rejected with a 400.")
     sql: StrictStr
-    __properties: ClassVar[List[str]] = ["async", "async_after_ms", "database_id", "default_catalog", "default_schema", "sql"]
+    __properties: ClassVar[List[str]] = ["async", "async_after_ms", "database_id", "default_catalog", "default_schema", "dialect", "sql"]
 
     model_config = ConfigDict(
         populate_by_name=True,
@@ -95,6 +96,11 @@ def to_dict(self) -> Dict[str, Any]:
         if self.default_schema is None and "default_schema" in self.model_fields_set:
             _dict['default_schema'] = None
 
+        # set to None if dialect (nullable) is None
+        # and model_fields_set contains the field
+        if self.dialect is None and "dialect" in self.model_fields_set:
+            _dict['dialect'] = None
+
         return _dict
 
     @classmethod
@@ -112,6 +118,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
             "database_id": obj.get("database_id"),
             "default_catalog": obj.get("default_catalog"),
             "default_schema": obj.get("default_schema"),
+            "dialect": obj.get("dialect"),
             "sql": obj.get("sql")
         })
         return _obj

test/test_query_request.py

@@ -41,6 +41,7 @@ def make_instance(self, include_optional) -> QueryRequest:
                 database_id = 'dbid6lguax1dxn9y1xj5gxnameyywl',
                 default_catalog = 'default',
                 default_schema = 'main',
+                dialect = 'hotsql',
                 sql = 'SELECT customer_id, sum(amount) AS total FROM orders GROUP BY customer_id ORDER BY total DESC LIMIT 10'
             )
         else: