josh-fell commented on code in PR #29166:
URL: https://github.com/apache/airflow/pull/29166#discussion_r1087126470
##########
airflow/providers/dbt/cloud/hooks/dbt.py:
##########
@@ -181,33 +181,46 @@ def __init__(self, dbt_cloud_conn_id: str =
default_conn_name, *args, **kwargs)
super().__init__(auth_type=TokenAuth)
self.dbt_cloud_conn_id = dbt_cloud_conn_id
+ @staticmethod
+ def _get_tenant_domain(conn: Connection) -> str:
+ if conn.schema:
+ warnings.warn(
+ "The `schema` parameter is deprecated and use within a dbt
Cloud connection will be removed "
+ "in a future version. Please use `host` instead and specify
the entire tenant domain name.",
+ category=DeprecationWarning,
+ stacklevel=2,
+ )
+ # Prior to deprecation, the connection.schema value could _only_
modify the third-level
+ # domain value while '.getdbt.com' was always used as the
remainder of the domain name.
+ tenant = f"{conn.schema}.getdbt.com"
+ else:
+ tenant = conn.host or "cloud.getdbt.com"
+
+ return tenant
+
@staticmethod
def get_request_url_params(
tenant: str, endpoint: str, include_related: list[str] | None = None
) -> tuple[str, dict[str, Any]]:
"""
Form URL from base url and endpoint url
- :param tenant: The tenant name which is need to be replaced in base
url.
+ :param tenant: The tenant domain name which is need to be replaced in
base url.
:param endpoint: Endpoint url to be requested.
:param include_related: Optional. List of related fields to pull with
the run.
Valid values are "trigger", "job", "repository", and "environment".
"""
data: dict[str, Any] = {}
- base_url = f"https://{tenant}.getdbt.com/api/v2/accounts/";
Review Comment:
Old logic that is no longer valid.
--
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: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
