diff --git a/sqlmesh/integrations/dlt.py b/sqlmesh/integrations/dlt.py index e8c53e7efb..d9cced8deb 100644 --- a/sqlmesh/integrations/dlt.py +++ b/sqlmesh/integrations/dlt.py @@ -63,10 +63,7 @@ def generate_dlt_models_and_settings( if db_type == "filesystem": connection_config = None else: - if dlt.__version__ >= "1.10.0": - client = pipeline.destination_client() - else: - client = pipeline._sql_job_client(schema) # type: ignore + client = pipeline.destination_client() config = client.config credentials = config.credentials configs = {