WIP: addition of trino airflow scheduler#2188
Conversation
|
|
| ## Airflow Scheduler | ||
| **Engine Name:** `trino` | ||
|
|
||
| The SQLMesh Trino Operator is similar to the [TrinoOperator](https://airflow.apache.org/docs/apache-airflow-providers-postgres/stable/_api/airflow/providers/postgres/operators/postgres/index.html), and relies on the same [TrinoHook](https://airflow.apache.org/docs/apache-airflow-providers-postgres/stable/_api/airflow/providers/postgres/hooks/postgres/index.html) implementation. |
There was a problem hiding this comment.
This section doc section has postgres links throughout instead of Trino (probably copy/pasted from postgres).
There was a problem hiding this comment.
Oh you got the source too :), yes copied let me correct it
docs/integrations/engines/trino.md
Outdated
| "trino", | ||
| default_catalog="<database name>", | ||
| engine_operator_args={ | ||
| "tromp_conn_id": "<Connection ID>" |
eakmanrq
left a comment
eakmanrq
left a comment
There was a problem hiding this comment.
Thanks for contributing this @SiddiqueAhmad! Were you able to test this and verify it works?
Most welcome, and yes it is working and running in my local setup. |
| pip install "sqlmesh[trino]" | ||
| ``` | ||
|
|
||
| The operator requires an [Airflow connection](https://airflow.apache.org/docs/apache-airflow/stable/howto/connection.html) to determine the target Trino account. Refer to [Trino connection](https://airflow.apache.org/docs/apache-airflow-providers-trino/stable/connections.html) for more details. |
There was a problem hiding this comment.
I see you fixed this link but you still have the links above this that are linking to Postgres.
eakmanrq
left a comment
eakmanrq
left a comment
There was a problem hiding this comment.
Thanks @SiddiqueAhmad! Will fix minor issues with links in docs in follow up PR.
|
I updated docs anyway thanks for merging and fixing too |
3 participants
No description provided.