potiuk commented on issue #27474: URL: https://github.com/apache/airflow/issues/27474#issuecomment-1317754922
> Someone from my team ran into a similar problem. I believe the problem stems from this line: https://github.com/apache/airflow/blob/main/airflow/models/connection.py#L215. > > If you use `BaseHook.get_connection()` passing in a "Postgres" type connection, the `conn_type` will be "postgres": https://github.com/apache/airflow/blob/main/airflow/providers/postgres/hooks/postgres.py#L66, meaning the final uri will start with `postgres` instead of `postgresql`. > > The fix as I see it, is to use either `BaseHook.get_hook(conn_id).get_uri()` if you want a generic solution or to use the `PostgresHook` directly but I guess the question is whether or not `BaseHook.get_uri()` is supposed to render the uri correctly in all cases? Would you like to make a PR to fix it @andersbogsnes ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
