Skip to content

Commit 98519c2

Browse files
authored
fix: compat with dlt 1.10.0 release (#4223)
1 parent 443b885 commit 98519c2

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

sqlmesh/integrations/dlt.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,10 @@ def generate_dlt_models_and_settings(
4949
if db_type == "filesystem":
5050
connection_config = None
5151
else:
52-
client = pipeline._sql_job_client(schema)
52+
if dlt.__version__ >= "1.10.0":
53+
client = pipeline.destination_client()
54+
else:
55+
client = pipeline._sql_job_client(schema) # type: ignore
5356
config = client.config
5457
credentials = config.credentials
5558
configs = {

0 commit comments

Comments
 (0)