diff --git a/dbt/adapters/fabric/__version__.py b/dbt/adapters/fabric/__version__.py index a26c301..582554e 100644 --- a/dbt/adapters/fabric/__version__.py +++ b/dbt/adapters/fabric/__version__.py @@ -1 +1 @@ -version = "1.7.3" +version = "1.7.4" diff --git a/dbt/adapters/fabric/fabric_connection_manager.py b/dbt/adapters/fabric/fabric_connection_manager.py index 1d2f37b..b84bb52 100644 --- a/dbt/adapters/fabric/fabric_connection_manager.py +++ b/dbt/adapters/fabric/fabric_connection_manager.py @@ -330,6 +330,16 @@ def open(cls, connection: Connection) -> Connection: application_name = f"dbt-{credentials.type}/{plugin_version}" con_str.append(f"APP={application_name}") + try: + if int(credentials.retries) > 0: + con_str.append(f"ConnectRetryCount={credentials.retries}") + + except Exception as e: + logger.debug( + "Retry count should be a integer value. Skipping retries in the connection string.", + str(e), + ) + con_str_concat = ";".join(con_str) index = []