Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion cosmos/profiles/athena/access_key.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ class AthenaAccessKeyProfileMapping(BaseProfileMapping):
Information about the dbt Athena profile that is generated can be found here:

https://github.com/dbt-athena/dbt-athena?tab=readme-ov-file#configuring-your-profile
https://docs.getdbt.com/docs/core/connect-data-platform/athena-setup
https://docs.getdbt.com/docs/local/connect-data-platform/athena-setup
"""

airflow_connection_type: str = "aws"
Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/bigquery/oauth.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ class GoogleCloudOauthProfileMapping(BaseProfileMapping):
Maps Airflow GCP connections to dbt BigQuery profiles that uses oauth via gcloud,
if they don't use key file or JSON.

https://docs.getdbt.com/docs/core/connect-data-platform/bigquery-setup#oauth-via-gcloud
https://docs.getdbt.com/docs/local/connect-data-platform/bigquery-setup
Comment thread
pankajastro marked this conversation as resolved.
https://airflow.apache.org/docs/apache-airflow-providers-google/stable/connections/gcp.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/bigquery/service_account_file.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ class GoogleCloudServiceAccountFileProfileMapping(BaseProfileMapping):
"""
Maps Airflow GCP connections to dbt BigQuery profiles if they use a service account file.

https://docs.getdbt.com/reference/warehouse-setups/bigquery-setup#service-account-file
https://docs.getdbt.com/docs/local/connect-data-platform/bigquery-setup
Comment thread
pankajastro marked this conversation as resolved.
https://airflow.apache.org/docs/apache-airflow-providers-google/stable/connections/gcp.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/bigquery/service_account_keyfile_dict.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ class GoogleCloudServiceAccountDictProfileMapping(BaseProfileMapping):
"""
Maps Airflow GCP connections to dbt BigQuery profiles if they use a service account keyfile dict/json.

https://docs.getdbt.com/reference/warehouse-setups/bigquery-setup#service-account-file
https://docs.getdbt.com/docs/local/connect-data-platform/bigquery-setup
https://airflow.apache.org/docs/apache-airflow-providers-google/stable/connections/gcp.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/clickhouse/user_pass.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
class ClickhouseUserPasswordProfileMapping(BaseProfileMapping):
"""
Maps Airflow generic connections using user + password authentication to dbt Clickhouse profiles.
https://docs.getdbt.com/docs/core/connect-data-platform/clickhouse-setup
https://docs.getdbt.com/docs/local/connect-data-platform/clickhouse-setup
"""

airflow_connection_type: str = "generic"
Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/databricks/oauth.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ class DatabricksOauthProfileMapping(BaseProfileMapping):
"""
Maps Airflow Databricks connections with the client auth to dbt profiles.

https://docs.getdbt.com/reference/warehouse-setups/databricks-setup
https://docs.getdbt.com/docs/local/connect-data-platform/databricks-setup
https://airflow.apache.org/docs/apache-airflow-providers-databricks/stable/connections/databricks.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/databricks/token.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ class DatabricksTokenProfileMapping(BaseProfileMapping):
"""
Maps Airflow Databricks connections with a token to dbt profiles.

https://docs.getdbt.com/reference/warehouse-setups/databricks-setup
https://docs.getdbt.com/docs/local/connect-data-platform/databricks-setup
https://airflow.apache.org/docs/apache-airflow-providers-databricks/stable/connections/databricks.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/duckdb/user_pass.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
class DuckDBUserPasswordProfileMapping(BaseProfileMapping):
"""
Maps Airflow DuckDB connections using local path mapping to dbt profiles.
https://docs.getdbt.com/docs/core/connect-data-platform/duckdb-setup
https://docs.getdbt.com/docs/local/connect-data-platform/duckdb-setup
https://github.com/astronomer/airflow-provider-duckdb
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/exasol/user_pass.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
class ExasolUserPasswordProfileMapping(BaseProfileMapping):
"""
Maps Airflow Exasol connections with a username and password to dbt profiles.
https://docs.getdbt.com/reference/warehouse-setups/exasol-setup
https://docs.getdbt.com/docs/local/connect-data-platform/exasol-setup
"""

airflow_connection_type: str = "exasol"
Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/mysql/user_pass.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
class MysqlUserPasswordProfileMapping(BaseProfileMapping):
"""
Maps Airflow MySQL connections using user + password authentication to dbt profiles.
https://docs.getdbt.com/reference/warehouse-setups/mysql-setup
https://docs.getdbt.com/docs/local/connect-data-platform/mysql-setup
https://airflow.apache.org/docs/apache-airflow-providers-mysql/stable/connections/mysql.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/oracle/user_pass.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
class OracleUserPasswordProfileMapping(BaseProfileMapping):
"""
Maps Airflow Oracle connections using user + password authentication to dbt profiles.
https://docs.getdbt.com/reference/warehouse-setups/oracle-setup
https://docs.getdbt.com/docs/local/connect-data-platform/oracle-setup
https://airflow.apache.org/docs/apache-airflow-providers-oracle/stable/connections/oracle.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/postgres/user_pass.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
class PostgresUserPasswordProfileMapping(BaseProfileMapping):
"""
Maps Airflow Postgres connections using user + password authentication to dbt profiles.
https://docs.getdbt.com/reference/warehouse-setups/postgres-setup
https://docs.getdbt.com/docs/local/connect-data-platform/postgres-setup
https://airflow.apache.org/docs/apache-airflow-providers-postgres/stable/connections/postgres.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/redshift/user_pass.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
class RedshiftUserPasswordProfileMapping(BaseProfileMapping):
"""
Maps Airflow Redshift connections to dbt Redshift profiles if they use a username and password.
https://docs.getdbt.com/reference/warehouse-setups/redshift-setup
https://docs.getdbt.com/docs/local/connect-data-platform/redshift-setup
https://airflow.apache.org/docs/apache-airflow-providers-amazon/stable/connections/redshift.html
"""

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
class SnowflakeEncryptedPrivateKeyPemProfileMapping(SnowflakeBaseProfileMapping):
"""
Maps Airflow Snowflake connections to dbt profiles if they use a user/private key.
https://docs.getdbt.com/docs/core/connect-data-platform/snowflake-setup#key-pair-authentication
https://docs.getdbt.com/docs/local/connect-data-platform/snowflake-setup
https://airflow.apache.org/docs/apache-airflow-providers-snowflake/stable/connections/snowflake.html
"""

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
class SnowflakeEncryptedPrivateKeyFilePemProfileMapping(SnowflakeBaseProfileMapping):
"""
Maps Airflow Snowflake connections to dbt profiles if they use a user/private key path.
https://docs.getdbt.com/docs/core/connect-data-platform/snowflake-setup#key-pair-authentication
https://docs.getdbt.com/docs/local/connect-data-platform/snowflake-setup
https://airflow.apache.org/docs/apache-airflow-providers-snowflake/stable/connections/snowflake.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/snowflake/user_pass.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
class SnowflakeUserPasswordProfileMapping(SnowflakeBaseProfileMapping):
"""
Maps Airflow Snowflake connections to dbt profiles if they use a user/password.
https://docs.getdbt.com/reference/warehouse-setups/snowflake-setup
https://docs.getdbt.com/docs/local/connect-data-platform/snowflake-setup
https://airflow.apache.org/docs/apache-airflow-providers-snowflake/stable/connections/snowflake.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/snowflake/user_privatekey.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
class SnowflakePrivateKeyPemProfileMapping(SnowflakeBaseProfileMapping):
"""
Maps Airflow Snowflake connections to dbt profiles if they use a user/private key.
https://docs.getdbt.com/docs/core/connect-data-platform/snowflake-setup#key-pair-authentication
https://docs.getdbt.com/docs/local/connect-data-platform/snowflake-setup
https://airflow.apache.org/docs/apache-airflow-providers-snowflake/stable/connections/snowflake.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/snowflake/user_privatekey_file.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
class SnowflakePrivateKeyFilePemProfileMapping(SnowflakeBaseProfileMapping):
"""
Maps Airflow Snowflake connections to dbt profiles if they use a user/private key path without a passphrase.
https://docs.getdbt.com/docs/core/connect-data-platform/snowflake-setup#key-pair-authentication
https://docs.getdbt.com/docs/local/connect-data-platform/snowflake-setup
https://airflow.apache.org/docs/apache-airflow-providers-snowflake/stable/connections/snowflake.html
"""

Expand Down
4 changes: 2 additions & 2 deletions cosmos/profiles/spark/thrift.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,8 @@
class SparkThriftProfileMapping(BaseProfileMapping):
"""
Maps Airflow Spark connections to dbt profiles if they use a thrift connection.
https://docs.getdbt.com/reference/warehouse-setups/spark-setup#thrift
https://airflow.apache.org/docs/apache-airflow-providers-apache-spark/stable/connections/spark.html
https://docs.getdbt.com/docs/local/connect-data-platform/spark-setup
https://airflow.apache.org/docs/apache-airflow-providers-apache-spark/stable/connections/index.html
"""

airflow_connection_type: str = "spark"
Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/starrocks/user_pass.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
class StarrocksUserPasswordProfileMapping(BaseProfileMapping):
"""
Maps Airflow MySQL connections using user + password authentication to dbt profiles.
https://docs.getdbt.com/docs/core/connect-data-platform/starrocks-setup
https://docs.getdbt.com/docs/local/connect-data-platform/starrocks-setup
"""

airflow_connection_type: str = "mysql" # StarRocks support mysql protocol
Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/teradata/user_pass.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
class TeradataUserPasswordProfileMapping(BaseProfileMapping):
"""
Maps Airflow Teradata connections using user + password authentication to dbt profiles.
https://docs.getdbt.com/docs/core/connect-data-platform/teradata-setup
https://docs.getdbt.com/docs/local/connect-data-platform/teradata-setup
https://airflow.apache.org/docs/apache-airflow-providers-teradata/stable/connections/teradata.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/trino/certificate.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
class TrinoCertificateProfileMapping(TrinoBaseProfileMapping):
"""
Maps Airflow Trino connections to Certificate Trino dbt profiles.
https://docs.getdbt.com/reference/warehouse-setups/trino-setup#certificate
https://docs.getdbt.com/docs/local/connect-data-platform/trino-setup#example-profilesyml-for-certificate
https://airflow.apache.org/docs/apache-airflow-providers-trino/stable/connections.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/trino/jwt.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ class TrinoJWTProfileMapping(TrinoBaseProfileMapping):
"""
Maps Airflow Trino connections to JWT Trino dbt profiles.

https://docs.getdbt.com/reference/warehouse-setups/trino-setup#jwt
https://docs.getdbt.com/docs/local/connect-data-platform/trino-setup#example-profilesyml-for-jwt
https://airflow.apache.org/docs/apache-airflow-providers-trino/stable/connections.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/trino/ldap.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ class TrinoLDAPProfileMapping(TrinoBaseProfileMapping):
"""
Maps Airflow Trino connections to LDAP Trino dbt profiles.

https://docs.getdbt.com/reference/warehouse-setups/trino-setup#ldap
https://docs.getdbt.com/docs/local/connect-data-platform/trino-setup#example-profilesyml-for-ldap
https://airflow.apache.org/docs/apache-airflow-providers-trino/stable/connections.html
"""

Expand Down
2 changes: 1 addition & 1 deletion cosmos/profiles/vertica/user_pass.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ class VerticaUserPasswordProfileMapping(BaseProfileMapping):
This seems to be a common approach also for `Postgres <https://github.com/apache/airflow/blob/0953e0f844fa5db81c2b461ec2433de1935260b3/airflow/providers/postgres/hooks/postgres.py#L138>`_, \
Redshift and Exasol since there is no ``database`` field in Airflow connection and ``schema`` is not required for the database connection.
.. seealso::
https://docs.getdbt.com/reference/warehouse-setups/vertica-setup
https://docs.getdbt.com/docs/local/connect-data-platform/vertica-setup
https://airflow.apache.org/docs/apache-airflow-providers-vertica/stable/connections/vertica.html
"""

Expand Down
Loading